Treasure Data Data Exchange Export Integration

Copy

• Copy for LLM

  Copy page as Markdown for LLMs
• View as Markdown

  Open this page as Markdown
• Open in ChatGPT

  Get insights from ChatGPT
• Open in Claude

  Get insights from Claude
• Cursorに接続

  CursorにMCPサーバーをインストール
• VS Codeに接続

  VS CodeにMCPサーバーをインストール

Treasure Dataコネクタを使用して、ジョブ結果をTreasure Dataデータベースに書き込むことができます。通常、このコネクタは、あるTreasure DataアカウントからTreasure Dataアカウントにデータをエクスポートするために使用されます。

あるTDアカウントから別のTDアカウントへのジョブ結果の書き込みに関するサンプルワークフローについては、Treasure Boxesを参照してください。

前提条件

• TD Toolbeltを含むTreasure Dataの基本的な知識。

基本的な使用方法

TD ConsoleまたはCLIから接続を設定できます。

TD Consoleで接続を作成する

TD Console内から接続を設定できます。アカウント間転送を完了するには、ターゲットのTreasure Dataアカウントから開始します。ターゲットアカウントプロファイルからAPI Key情報をコピーする必要があります。

API Key情報を取得する

1. TD Console > My Settingsに移動します。管理者権限が必要です。

   

2. API Keysを選択します。

   

3. 必要に応じてアクセスを検証します。

   

4. 検証が完了してプロファイルに戻ると、マスターキーと書き込み専用キーの両方が表示されます。Write-only API keyをハイライトします。それを選択すると、自動的にクリップボードにコピーされます。

   

新しい認証を作成する

データ接続を設定する際、統合にアクセスするための認証を提供します。Treasure Dataでは、認証を設定してからソース情報を指定します。

1. TD Consoleを開きます。

2. Integrations Hub > Catalogに移動します。

3. Treasure Dataタイルを検索して選択します。

   

4. Createを選択します。ターゲットアカウントから書き込み専用API Keyを入力します。API Hostnameには、エクスポートに使用するサーバーを入力します。フィールドを空白のままにして、リージョンのデフォルトサーバーを使用できます。または、次のいずれかの値を入力できます：

   • US: api.treasuredata.com
   • JP: api.treasuredata.co.jp
   • EU01: api.eu01.treasuredata.com
   • AP02 (Korea): api.api02.treasuredata.com

5. Continueを選択します。接続に名前を付けてCreate Connectionを選択します。

Treasure Data Connectorで出力を指定する

転送を作成するには、データ接続を設定するクエリを作成または再利用します。

1. TD Consoleを開きます。

2. Data Workbench > Queriesに移動します。データをエクスポートするために使用する予定のクエリをハイライトします。

3. クエリエディタの右上にあるExport Resultsを選択します。

   

   SELECT code, COUNT(1) FROM www_access GROUP BY code

4. Choose Integrationダイアログが開きます。

   

5. Use Existing Integrationを選択し、保存された認証の名前を検索します。

パラメータの指定

1. 認証を選択した後、Nextを選択します。Export Resultsダイアログが開きます。

   

2. パラメータを指定し、Doneを選択します。

(オプション) Query Export ジョブをスケジュールする

Scheduled Jobs と Result Export を使用して、指定したターゲット宛先に出力結果を定期的に書き込むことができます。

Treasure Data のスケジューラー機能は、高可用性を実現するために定期的なクエリ実行をサポートしています。

2 つの仕様が競合するスケジュール仕様を提供する場合、より頻繁に実行するよう要求する仕様が優先され、もう一方のスケジュール仕様は無視されます。

例えば、cron スケジュールが '0 0 1 * 1' の場合、「月の日」の仕様と「週の曜日」が矛盾します。前者の仕様は毎月 1 日の午前 0 時 (00:00) に実行することを要求し、後者の仕様は毎週月曜日の午前 0 時 (00:00) に実行することを要求するためです。後者の仕様が優先されます。

TD Console を使用してジョブをスケジュールする

1. Data Workbench > Queries に移動します

2. 新しいクエリを作成するか、既存のクエリを選択します。

3. Schedule の横にある None を選択します。

4. ドロップダウンで、次のスケジュールオプションのいずれかを選択します:

   ドロップダウン値	説明
   Custom cron...	Custom cron... の詳細を参照してください。
   @daily (midnight)	指定されたタイムゾーンで 1 日 1 回午前 0 時 (00:00 am) に実行します。
   @hourly (:00)	毎時 00 分に実行します。
   None	スケジュールなし。

Custom cron... の詳細

 *    *    *    *    *
 -    -    -    -    -
 |    |    |    |    |
 |    |    |    |    +----- day of week (0 - 6) (Sunday=0)
 |    |    |    +---------- month (1 - 12)
 |    |    +--------------- day of month (1 - 31)
 |    +-------------------- hour (0 - 23)
 +------------------------- min (0 - 59)

次の名前付きエントリを使用できます:

• Day of Week: sun, mon, tue, wed, thu, fri, sat.
• Month: jan, feb, mar, apr, may, jun, jul, aug, sep, oct, nov, dec.

各フィールド間には単一のスペースが必要です。各フィールドの値は、次のもので構成できます:

1. (オプション) Delay execution を有効にすることで、クエリの開始時刻を遅延させることができます。

クエリを実行する

クエリに名前を付けて保存して実行するか、単にクエリを実行します。クエリが正常に完了すると、クエリ結果は指定された宛先に自動的にエクスポートされます。

(オプション) Delay execution を有効にすることで、クエリの開始時刻を遅延させることができます。

Audience Studio で Segment をアクティベートする

Audience Studio で activation を作成することで、segment データをターゲットプラットフォームに送信することもできます。

1. Audience Studio に移動します。
2. parent segment を選択します。
3. ターゲット segment を開き、右クリックして、Create Activation を選択します。
4. Details パネルで、Activation 名を入力し、前述の Configuration Parameters のセクションに従って activation を設定します。
5. Output Mapping パネルで activation 出力をカスタマイズします。

• Attribute Columns
  • Export All Columns を選択すると、変更を加えずにすべての列をエクスポートできます。
  • + Add Columns を選択して、エクスポート用の特定の列を追加します。Output Column Name には、Source 列名と同じ名前があらかじめ入力されます。Output Column Name を更新できます。+ Add Columns を選択し続けて、activation 出力用の新しい列を追加します。
• String Builder
  • + Add string を選択して、エクスポート用の文字列を作成します。次の値から選択します:
    • String: 任意の値を選択します。テキストを使用してカスタム値を作成します。
    • Timestamp: エクスポートの日時。
    • Segment Id: segment ID 番号。
    • Segment Name: segment 名。
    • Audience Id: parent segment 番号。

6. Schedule を設定します。

• スケジュールを定義する値を選択し、オプションでメール通知を含めます。

7. Create を選択します。

CLIからのオンデマンドジョブの場合

オンデマンドジョブの場合は、td queryコマンドに--resultオプションを追加するだけです。ジョブが完了すると、結果はtestdbデータベース内のoutput_tableに書き込まれます。

$ td query --result 'td://@/testdb/output_table' \
  -w -d testdb \
  "SELECT code, COUNT(1) FROM www_access GROUP BY code"

スケジュールされたジョブの場合

スケジュールされたジョブの場合は、ジョブをスケジュールするときに--resultオプションを追加するだけです。ジョブが実行されるたびに、結果はoutput_tableに書き込まれます。

$ td result:create mydb td://@/testdb
$ td sched:create hourly_count_example "0 * * * *" \
  -d testdb "select count(*) from www_access" \
  --result mydb:output_table

データを変更する2つの方法

2つの方法でデータを追加または削除できます：

• append
• replace

td://@/testdb/output_table              # append
td://@/testdb/output_table?mode=append  # append
td://@/testdb/output_table?mode=replace # replace

Append

これはデフォルトモードです。クエリ結果はテーブルに追加されます。テーブルがまだ存在しない場合は、新しいテーブルが作成されます。この操作は冪等ではありません。同じ呼び出しを繰り返し行っても同じ結果を生成することはできません。このモードはatomicではありません。

Replace

テーブルがすでに存在する場合、既存のテーブルの行はクエリ結果で置き換えられます。テーブルがまだ存在しない場合は、新しいテーブルが作成されます。

次の3つのステップを単一のトランザクションで実行することにより、atomicity（テーブルの消費者が常に一貫したデータを持つように）を実現します。

1. 一時テーブルを作成します。
2. 一時テーブルに書き込みます。
3. 既存のテーブルを一時テーブルでアトミックに置き換えます。