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の列となります。

(オプション) 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を使用したジョブのスケジューリングを参照してください。