Amplitude 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サーバーをインストール

Amplitude Import Integrationの詳細はこちら。

クエリを使用して、Treasure Dataに保存されているデータからAmplitude Eventsを作成します。

前提条件

• TD Toolbeltを含む、Treasure Dataの基本的な知識。
• Treasure Dataに権限を付与できるAmplitudeアカウント。

Amplitudeアカウントの作成

Amplitudeアカウントをお持ちでない場合は、https://amplitude.comにアクセスして登録してください。その後、組織とプロジェクトを作成します。プロジェクトを作成すると、そのプロジェクト用のAPIキーを受け取ります。

Amplitudeユーザーアクティビティ

Amplitudeコンソールでは、ユーザーアクティビティを表示してAmplitudeイベントを探索できます。

使い方

TDコンソールに移動し、Queriesを選択して新規クエリを選択し、クエリエディタにアクセスします。クエリ言語を選択してクエリを記述します。「結果を出力」を選択します。

新しいAmplitude接続を作成するか既存の接続を選択する

新しい接続の作成:

既存の接続の選択:

オプション: 追加設定を完了する

新しいAmplitude接続を作成するか既存の接続を選択した後、追加設定ポップアップが表示されます。例:

Amplitudeイベントを入力するためのクイッククエリを記述する

次の例では、クエリ結果を出力する前に、Amplitudeプロジェクトにはイベントがありません:

Treasure Dataで、AmplitudeをResult Exportとして次のクエリを実行します:

SELECT
  user_id,
  device_id,
  event_type,
  event_properties,
  country,
  time
FROM (
  VALUES(
    'a@gmail.com',
    'f925065b-4d56-486f-a2be-e97952e62925',
    'game_open',
    '{"load_time":0.0619166532,"dates":["sunday","monday"],"source":"notification"}',
    'United States',
    1515083919310
  ),
  (
    'b@gmail.com',
    'b36c8c80-71a0-4de4-8bcb-c801f5c1c6c3',
    'select_avatar',
    '{"load_time":0.0517593568,"dates":["friday","sunday"],"source":"notification"}]',
    'United States',
    1515083943092
  ),
  (
    'c@gmail.com',
    'e44a1024-c4bb-4eef-a02a-f2a7b3bf68b3',
    'watch_tutorial',
    '{"load_time":0.0689998562,"dates":["sunday","monday"],"source":"notification"}',
    'United States',
    1515083970894
  ),
  (
    'd@gmail.com',
    '8274fee1-7222-4e41-83ed-fb5521d5f4b8',
    'game_start',
    '{"load_time":0.0976384392,"dates":["friday","monday"],"source":"notification"}',
    'United States',
    1515084000948
  ),
  (
    'e@gmail.com',
    '29ba193d-0955-4084-9640-bb4d8ba9a23f',
    'ad_clicked',
    '{"load_time":0.0708434955,"dates":["monday","saturday"],"source":"notification"}',
    'United States',
  )
) tbl(
  user_id,
  device_id,
  event_type,
  event_properties,
  country,
  time
)

前述のクエリはソーステーブルを必要としないため、テストが簡単ですが、それでもデータベースを選択する必要があります。「sample_datasets」または他の任意のテーブルを選択してください。また、SQLダイアレクトとしてPrestoが選択されていることを確認してください。

クエリは数秒で完了します。Amplitudeアカウントにログインし、User Activityを確認してください。次のように表示されるはずです:

複数の値を単一のJSON列値に結合する

複数の値がある場合、次のように単一のJSON列値に結合できます:

SELECT CAST(MAP(ARRAY['source', 'status', 'action'], ARRAY['notification', 'pending', 'add']) AS JSON) AS event_properties

これにより、event_propertiesのシンプルなJSONオブジェクトが作成されます: '{"action":"add","source":"notification","status":"pending"}'

次のように、より複雑な列を作成できます:

SELECT CAST(MAP(ARRAY['load_time', 'source', 'dates'], ARRAY[CAST (0.8371 AS JSON), CAST ('notification' AS JSON), CAST(ARRAY['monday', 'tuesday'] AS JSON)]) AS JSON) AS event_properties

これにより、event_properties値として次のJSONオブジェクトが作成されます: '{"dates":["monday","tuesday"],"load_time":0.8371,"source":"notification"}'

Amplitudeイベントを生成するためのTDテーブルへのクエリを記述する

Amplitudeのレコードを作成するために使用できるTDデータベーステーブルの例は次のとおりです:

Treasure Data Consoleで、クエリエディタに移動し、クエリを入力します。例:

SELECT user_id, device_id, event_type, event_properties, country, event_time AS time FROM events

Output resultsを選択して、データをAmplitudeに送信します。次に、既存のコネクタを選択するか、api_keyを使用して新しい接続を作成します。

コネクタが選択または作成されたら、クエリエディタでRunを選択してデータ転送を開始します。

Event Deduplication

Amplitudeによって重複イベントが保存されないように、各イベントにinsert_idを送信することを強くお勧めします。insert_idはイベントの一意の識別子です。Amplitudeは、同じinsert_idを持つイベントが7日以内に送信された場合、それらのイベントを削除します。

Insert IDの自動生成を無効にしないと、TDは各レコードに対して自動的にSHA256のinsert_idを生成します。

Insert IDの自動生成を無効にする場合、insert_idはユーザーが提供する必要があります。

Amplitude列

次の表は、Amplitudeでサポートされているイベント列とデータ型の一覧です。

イベント標準列

1,2,3,4,5の脚注を表示

イベントオプション列

Identifyスキーマとデータ型

User Properties Fields (Identify Target Only)

または、Identify Schemaリストの列にない任意のフィールドはuser_propertiesの列となります。

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 を選択します。

(オプション) 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 を有効にすることで、クエリの開始時刻を遅延させることができます。

(オプション) CLIを使用したエクスポート連携

CLI(Toolbelt)を使用して、td queryコマンドの--resultオプションで、Shopifyサーバーにエクスポートする情報を指定することで、結果をShopifyにエクスポートすることもできます。td queryコマンドの詳細については、TD Toolbelt: Query Commandsを参照してください。

TD Toolbeltで使用されるyml設定ファイルのオプションはJSON形式であり、一般的な構造は以下の通りです。

• Event Targetの場合

out:
  api_key: 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX'
  target: 'event'
  disable_auto_generation_insert_ids: false
  region: 'US'
  events_per_batch: 10

• Identifyターゲットの場合

out:
  type: amplitude
  target: identify
  api_key: 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX'
  region: EU
  operation: set
  skip_invalid_records: false

パラメータ

CLIの使用例

イベントのアップロード

td query \
--result '{"type":"amplitude","api_key":"api_key","target":"event","region":"US","disable_auto_generation_insert_ids":"false","events_per_batch":10}'  \
-d sample_database \
"select user_id,device_id,event_type,value from tbl_shop" \
-T presto

Identifyのアップロード

td query --result \
'{"type":"amplitude","api_key":"api_key","target":"identify","region":"US","operation":"add","skip_invalid_records":true}'\
-d sample_database \
"select user_id,device_id,user_properties,value from tbl_shop" \
-T presto

関連項目

• Result Exportをスケジュールして、定期的にターゲット先にデータをアップロードできます。TD Consoleを使用したジョブのスケジューリングを参照してください。