# TD IntegrationsでTD Workflowを使用する ほとんどのバッチインポートおよびエクスポートintegrationsは、より高度なデータパイプラインの一部としてworkflowsに追加できます。基本的な手順は次のとおりです: - YAMLファイルであるworkflow定義を準備します。importインテグレーションには**td_load>** operatorを、exportインテグレーションには**td>** operatorを使用します。 - TD Consoleまたはコマンドラインインターフェースからworkflowを実行します ## import integrationの事前定義されたSourceを使用する import integration用のSourceをすでに作成している場合は、そのユニークIDを使用してworkflow内で実行できます 1. **Integration Hub**でターゲットのSourceを特定します 2. `**...**`メニューを選択し、**Copy Unique ID**を選択します ![](/assets/using-td-workflow-with-td-integrations-2024-08-09.f0acc37b697f4693c6d5e5f2fccc80706461e31eff5d1baabef37ed64a2c2773.18b4736f.png) 3. **td_load>** operatorを使用してworkflowタスクを定義します。 ``` +my_first_worklfow_step: td_load>: unique_id_of_your_source ``` ## import integration用の設定ファイルを使用する または、import connectorのすべてのパラメータをYAMLファイルに記述し、workflow定義でそれを参照することもできます 1. import integration用の設定ファイル(例:**load_config.yml**)を準備します。例と完全なパラメータの説明は、各integrationのドキュメントに記載されています 2. それを参照するworkflowを定義します ```yaml +my_first_workflow_step: td_load>: config/load_config.yml database: my_database_name table: my_table_name ``` ## export integrationを含むworkflowを定義する クエリを実行し、その結果をexport integrationにアップロードするworkflowタスクを定義する方法がいくつかあります 1. **td>** operatorと事前定義されたAuthenticationの**name**を使用する ![](/assets/using-td-workflow-with-td-integrations-2024-08-09-1.a52133de619be06eed4ff85425ba571cd590adc97e5e7d600dd617864ea051f6.18b4736f.png) ``` +query_and_export: td>: queries/sample.sql database: my_database result_connection: ads_with_oauth result_settings: parameter1: value1 parameter2: value2 .... ``` パラメータの説明は、以下のSFCC Export Integrationのように、各integrationのドキュメントに記載されています ![](/assets/using-td-workflow-with-td-integrations-2024-08-14.c8d92f28ae6ba0e800fa2fda32d81638c3713763f4f9e5dd43fdb074178ff49e.18b4736f.png) 2. **td>** operatorと事前定義されたAuthenticationの**ID**を使用する ![](/assets/google-ads-import-integration-v2-2024-08-06-9.fdc162a377e20998a8f41e69c38afef49bbd1ab0b84f6b913fd06fe82b2010f3.7c52a81f.png) ```yaml +query_data_and_write_result_with_existing_authentication_by_url: td>: query: 'select * from wf_test' database: my_database result_url: '{"type": "google_adwords_v2", "td_authentication_id": 330392, "bucket": "qa-auto-test-3", "path": "viet/assume_role_from_eu01.csv"}' ``` 3. **td_run>** operatorと保存済みクエリを使用する ```yaml +query_a_saved_sql: td_run>: presto_select_all_s3v2 database: my_database result_url: '{"type":"s3_v2", "td_authentication_id":260370, "bucket": "qqus-east-1", "path":"foo/wf_jan16_1444.csv"}' ``` ### workflowを実行する workflowを定義して実行するには2つのオプションがあります 1. **TD Console** > **Data Workbench** > **Workflows**のグラフィカルインターフェースを使用する 2. TD Toolbeltのコマンドラインインターフェースを使用する TD Consoleを使用する方がコマンドラインインターフェースよりも簡単ですが、TD CLIツールはより複雑な設定のオプションを提供します。 TD Workflowの構文と使用方法の詳細については、[こちら](https://docs.treasuredata.com/articles/pd/about-treasure-workflow)を参照してください