Skip to content

Treasure Data for Currents

トレジャーデータは、複数のソースから情報を収集し、マーケティングスタックの他のさまざまなロケーションにルーティングする顧客データプラットフォーム（CDP）です。

Brazeとトレジャーデータの統合により、2つのシステム間の情報の流れを制御できます。Currentsを使用すると、Brazeのイベントデータをトレジャーデータにストリーミングし、グローススタック全体で活用できます。

推奨される方法は、トレジャーデータのBraze Currents Streamingコネクターと、BrazeのカスタムCurrentsエクスポートを組み合わせることです。このアプローチには以下のメリットがあります。

  • Brazeからトレジャーデータへのリアルタイムイベントストリーミング
  • イベントタイプごとの自動テーブルルーティング（オプション）
  • JSONパースが不要なフラットでSQLクエリ可能なスキーマ

前提条件

必要条件 説明
トレジャーデータアカウント このパートナーシップを活用するには、アクティブなトレジャーデータアカウントが必要です。
Currents トレジャーデータにデータをエクスポートするには、アカウントにBraze Currentsを設定する必要があります。
Braze Currents Streamingコネクター トレジャーデータアカウントでBraze Currents Streamingコネクター（ベータ版）を有効にするには、トレジャーデータサポートにお問い合わせください。
トレジャーデータWrite APIキー トレジャーデータのWrite APIキーは、Brazeからのインバウンドストリームを認証します。

統合

ステップ1：トレジャーデータでコネクターを設定する

  1. トレジャーデータコンソールで、Connections > New Connectionに移動します。
  2. Braze Currents Streamingを選択します。
  3. Authenticationで、トレジャーデータのWrite APIキーを入力します。
  4. Source Settingsで、以下を設定します。
フィールド 説明
Source Name この接続のわかりやすい名前
Datastore Plazmaを選択
Database イベントが保存されるトレジャーデータのデータベース
Table デフォルトの宛先テーブル
Multiple Tables 各Brazeイベントタイプを個別のテーブルにルーティングする場合に選択
  1. 保存後、Unique ID（task_id）をコピーします。この値は次のステップで必要になります。

ステップ2：BrazeでカスタムCurrentsエクスポートを作成する

Braze Currents UIのTreasure Data ExportオプションはレガシーのPostback API方式を使用しており、現在は推奨されていません。代わりにカスタムCurrentsエクスポートを使用してください。

  1. Brazeで、パートナー連携 > Data Exportに移動します。
  2. Create New Current > Custom Currents Exportを選択します。
  3. 統合名とエラー通知用の連絡先メールアドレスを入力します。
  4. Credentialsで、トレジャーデータリージョンのエンドポイントURLを入力します。トレジャーデータのWrite APIキーをBearer Tokenとして入力します。
リージョン エンドポイントURL
US https://braze-in-streaming.treasuredata.com/v1/task/{TASK_ID}
EU https://braze-in-streaming.eu01.treasuredata.com/v1/task/{TASK_ID}
AP02 https://braze-in-streaming.ap02.treasuredata.com/v1/task/{TASK_ID}
Tokyo https://braze-in-streaming.treasuredata.co.jp/task/v1/{TASK_ID}

{TASK_ID}をステップ1でコピーしたUnique IDに置き換えてください。

  1. エクスポートするイベントタイプを選択します。カスタムCurrents接続では、識別済みユーザーとexternal_user_idを持たないユーザーの両方のイベントを送信できます。トレジャーデータは両方を取り込みます。
  2. Launch Currentを選択します。

データのクエリ

イベントが流れ始めたら、SQLでクエリできます。トレジャーデータはペイロードをフラット化するため、JSONのパースは不要です。

1
2
3
4
5
6
7
8
9

SELECT
  id AS event_id,
  event_type,
  user_external_user_id,
  properties_campaign_name,
  properties_email_address,
  time
FROM your_database.your_table
WHERE TD_INTERVAL(time, '-1d', 'JST')

Multiple Tablesを選択した場合、各イベントタイプは個別のテーブルに格納されます（例：users_message_email_openやusers_behaviors_purchase）。

データが到着していることを確認するには、Currentを起動してから数分後にカウントクエリを実行します。

1
2
3

SELECT COUNT(*)
FROM your_table
WHERE TD_INTERVAL(time, '-1h')

データスキーマ

トレジャーデータはネストされたJSONを最大2階層までフラット化します。

JSONタイプ トレジャーデータのカラムタイプ
string string
number long
boolean string
array JSON string
object（レベル1） field_name
object（レベル2） parent_field_name_field_name
null 省略

カラム名には小文字とアンダースコアのみが使用されます。

制限事項

項目 制限
最大ペイロードサイズ リクエストあたり1 MB
バッチサイズ バッチあたり100イベント（デフォルト）

統合の詳細

Brazeでは、Currentsイベント用語集にリストされているすべてのデータをトレジャーデータにエクスポートできます。これには、メッセージエンゲージメントイベントおよび顧客行動イベントのすべてのプロパティが含まれます。

エクスポートされたデータのペイロード構造は、カスタムHTTPコネクターのペイロード構造と同じです。サンプルペイロードは、カスタムHTTPコネクターのサンプルリポジトリで確認できます。

レガシーPostback方式からの移行

以前BrazeでTreasure Data Export（Postback）を使用していた場合は、以下の手順で移行してください。

  1. この記事のカスタムCurrentsエクスポートのセットアップを完了します。
  2. 新しいテーブルにイベントが流れていることを確認します。
  3. Brazeで古いPostbackベースのCurrentを無効にします。

レガシーデータは生のJSON配列として保存されており、JSON_PARSEとUNNESTでクエリできます。ストリーミングコネクターを通じて取り込まれた新しいデータは、データスキーマで説明されているフラットスキーマを使用します。
New Stuff!