入力値が揃ったタイミングで処理を実行したい

1. 「time」、「uniqueNumber」、「Name」の3つのカラムを持つテンポラリテーブルを作成します。

使用するコンポーネントアイコンは、 「書き込み」です。

2. 1秒ごとに現在時刻と自動でインクリメントされる番号を取得し、テンポラリテーブルの「time」カラムと「uniqueNumber」カラムに書き込む処理を作成します。

使用するコンポーネントアイコンは、「定期イベント」および「書き込み」です。

3. 監視対象ファイルを監視し、ファイルに行が書き込まれるとその時刻を取得してテンポラリテーブルの「Name」カラムに書き込む処理を作成します。

使用するコンポーネントアイコンは、「更新監視処理」および「書き込み」です。

4. 2. および3. のストリームフローで書かれた値を「time」カラムをキーとして結合し、「time」、「uniqueNumber」、「Name」の3つのカラムすべてに値が揃った場合は標準出力に値を出力する処理を作成します。

使用するコンポーネントアイコンは、「レコード監視」および「標準出力」です。

1. テンポラリテーブルの設定（グローバルリソース）を行います。

1. ツールパレットの基本-テンポラリテーブル-書き込みをスクリプトキャンバスにドラッグ&ドロップします。

   新規書き込み処理ダイアログが表示されます。

2. 「必須設定」タブの「テーブル」で、「追加」を選択します。

   新規テンポラリテーブル設定ダイアログが表示されます。

3. 以下のようにテンポラリテーブルを設定し、完了ボタンをクリックします。

   • 追加ボタンをクリックして、列名「time」、「uniqueNumber」、「Name」の3つのカラムを作成します。

   • 「データ生存期間」および「クリーンナップ間隔」を入力します。

     ここでは「60」を入力します。

   

4. 完了ボタンをクリックします。

2. 1秒ごとに自動でインクリメントされる番号と時刻を、テンポラリテーブルへ書き込むストリームフローを作成します。

1. ツールパレットの基本-基本-定期イベントをスクリプトキャンバスにドラッグ&ドロップします。

   新規定期イベント処理ダイアログが表示されます。

2. 「インターバル」に「1」を入力し、完了ボタンをクリックします。

   

3. スクリプトキャンバスで、定期イベントアイコンを書き込みアイコンへドラッグ&ドロップします。

マッピングを追加する旨のメッセージが出た場合ははいボタンをクリックしてください。

mapping_1アイコンとストリームフローが作成されます。

4. スクリプトキャンバスで「mapping_1」をダブルクリックします。

Mapperエディタが表示されます。

5. ツールパレットから以下のロジックをMapperエディタにドラッグ&ドロップします。

• 現在日時を取得するため、日付-基本-現在日時(OSタイムゾーン)

• 出力する日時のフォーマットを指定するため、文字列-日付-日時フォーマッティング(定型書式)

• 自動でインクリメントされる番号を出力するため、数値-基本-インクリメント

Mapperエディタに各ロジックが配置されます。

6. 配置したロジックのプロパティを入力します。

1. 日時フォーマッティング(定型書式)ロジックをダブルクリックします。

   日時フォーマッティング(定型書式)ロジックのプロパティダイアログが表示されます。

2. 「フォーマット」のプルダウンメニューからフォーマットを選択します。

   ここでは「hh:mm:ss」を選択します。

3. 必要に応じて「コメント」も入力し、完了ボタンをクリックします。

4. 必要に応じて現在日時(OSタイムゾーン)およびインクリメントロジックをそれぞれダブルクリックして「コメント」を入力し、完了ボタンをクリックします。

7. 現在日時(OSタイムゾーン)ロジックを日時フォーマッティング(定型書式)ロジックへドラッグ&ドロップします。

現在日時(OSタイムゾーン)ロジックから日時フォーマッティング(定型書式)ロジックへのマッピングリンクが表示されます。

8. 日時フォーマッティング(定型書式)ロジックを出力先（ここでは「time」）へドラッグ&ドロップします。

日時フォーマッティング(定型書式)ロジックから「time」へマッピングリンクが表示されます。

9. インクリメントロジックを出力先（ここでは「uniqueNumber」）へドラッグ&ドロップします。

インクリメントロジックから「uniqueNumber」へマッピングリンクが表示されます。

これで「mapping_1」の設定ができました。スクリプトキャンバスに戻ります。

10. ファイルに行が書き込まれるたびに取得時刻と行の内容をテンポラリテーブルへ書き込むストリームフローを作成します。

1. ツールパレットの基本-テンポラリテーブル-書き込みをスクリプトキャンバスにドラッグ&ドロップします。

   新規書き込み処理ダイアログが表示されます。

2. 「必須設定」タブの「テーブル」で、手順1. で追加したテーブルを選択します。

   

3. 完了ボタンをクリックします。

4. ツールパレットのファイル-基本-更新監視をスクリプトキャンバスにドラッグ&ドロップします。

   新規更新監視処理ダイアログが表示されます。

5. 「必須設定」タブの「ファイル名」で、更新監視対象のファイルを指定します。

   

6. 完了ボタンをクリックします。

11. スクリプトキャンバスで、更新監視アイコンを書き込みアイコンへドラッグ&ドロップします。

マッピングを追加する旨のメッセージが出た場合ははいボタンをクリックしてください。

mapping_2アイコンとストリームフローが作成されます。

12. スクリプトキャンバスで「mapping_2」をダブルクリックします。

Mapperエディタが表示されます。

13. 入力元の「payload」を出力先の「Name」へドラッグ&ドロップします。

「payload」から「Name」へマッピングリンクが表示されます。

これで「mapping_2」の設定ができました。スクリプトキャンバスに戻ります。

14. テンポラリテーブルのすべてのカラムに値が揃ったときに標準出力へ値を出力するストリームフローを作成します。

1. ツールパレットの基本-テンポラリテーブル-レコード監視をスクリプトキャンバスにドラッグ&ドロップします。

   新規レコード監視処理ダイアログが表示されます。

2. 以下のように監視対象を設定します。

   • 「必須設定」タブの「テーブル」で、手順1. で作成したテンポラリテーブルを選択します。

   • 「データ監視対象」の「監視対象」すべてにチェックを入れます。

   

3. 完了ボタンをクリックします。

4. ツールパレットの基本-基本-標準出力をスクリプトキャンバスにドラッグ&ドロップします。

   新規標準出力処理ダイアログが表示されます。

   

5. 完了ボタンをクリックします。

15. スクリプトキャンバスで、レコード監視アイコンを標準出力アイコンへドラッグ&ドロップします。

マッピングを追加する旨のメッセージが出た場合ははいボタンをクリックしてください。

mapping_3アイコンとストリームフローが作成されます。

16. スクリプトキャンバスで「mapping_3」をダブルクリックします。

Mapperエディタが表示されます。

17. 出力先のスキーマを作成します。

ここでは「stdout」の配下に「root」要素を作成し、「root」要素の子要素として「time」、「uniqueNumber」、および「Name」を作成します。

1. 出力先の「stdout」を右クリックして、メニューからルート要素の追加を選択します。

   「root」要素が作成されます。

2. 「root」要素を右クリックして、メニューから追加-子要素を選択します。

   出力要素の追加ダイアログが表示されます。

3. 「要素名」に「time」を入力します。「コメント」は必要に応じて入力してください。

4. OKボタンをクリックします。

   「root」配下に「time」要素が作成されます。

5. 「time」と同じ手順で「root」配下に「uniqueNumber」要素および「Name」要素を作成します。

18. 入力元から出力先へ以下をドラッグ&ドロップします。

• 入力元の「time」を出力先の「time」へ

• 入力元の「uniqueNumber」を出力先の「uniqueNumber」へ

• 入力元の「Name」を出力先の「Name」へ

19. スクリプトを保存します。

スクリプトの保存方法については「ファーストステップガイド」を参照してください。