Amplitude#
API キー、シークレット、過去データの取得開始日を使って Amplitude を接続します。このソースは titan.amplitude に 1 個の固定テーブルを書き込みます。
select
uuid,
event_id,
event_type
from titan.amplitude.events
limit 10Amplitudeを接続する#
アプリを開き、アプリを接続を選択してから、Amplitudeを選択します。
API キー、シークレット、過去データの取得開始日を入力します。
テーブルを確認してからソースを保存します。
初回の実行が完了するまで同期履歴を確認します。
認証情報はシークレットとして保存されます。レイクの列になったり、クエリ結果に表示されたりすることはありません。
同期の動作#
初回は設定した過去データの取得開始日から実行します。以降は最後に完了した期間から再開します。
新しいソースは接続時に同期し、その後はスケジュールに従います。デフォルトのスケジュールでは、組織のタイムゾーンで平日の 5:00、10:00、15:00、20:00 と日曜日の 20:00 に同期し、各ソースはその時刻から 30 分以内に開始します。実行が中断しても、完了した進捗を保持して安全に再試行します。
すべてのレイクのテーブルにはシステム列 _synced_at と _deleted もあります。以下の列リファレンスにはソースの列のみを記載しています。
テーブルリファレンス#
events#
titan.amplitude.events には 40 個のソース列があります。
ソースのフィールド uuid。
ソースのフィールド event_id。
ソースのフィールド event_type。
ソースのフィールド event_time。
ソースのフィールド user_id。
ソースのフィールド session_id。
ソースのフィールド amplitude_id。
ソースのフィールド amplitude_attribution_ids。
ソースのフィールド server_received_time。
ソースのフィールド server_upload_time。
ソースのフィールド client_upload_time。
ソースのフィールド client_event_time。
ソースのフィールド sample_rate。
ソースのフィールド start_version。
ソースのフィールド app。
ソースのフィールド library。
ソースのフィールド device_carrier。
ソースのフィールド processed_time。
ソースのフィールド version_name。
ソースのフィールド paying。
ソースのフィールド platform。
ソースのフィールド os_name。
ソースのフィールド os_version。
ソースのフィールド device_id。
ソースのフィールド device_type。
ソースのフィールド device_family。
ソースのフィールド language。
ソースのフィールド country。
ソースのフィールド region。
ソースのフィールド city。
ソースのフィールド dma。
ソースのフィールド ip_address。
ソースのフィールド data。
ソースのフィールド event_properties。
ソースのフィールド user_properties。
ソースのフィールド group_properties。
ソースのフィールド groups。
ソースのフィールド location_lat。
ソースのフィールド location_lng。
ソースのフィールド insert_id。
削除と履歴#
行はソースのキーでマージされます。ソース側で行の削除を確認できた場合、Supernova は行を残して _deleted を設定します。クエリで履歴を含めるかどうかを選べます。現在の状態だけを取得するには where not _deleted で絞り込んでください。