Treasure Data CDP連携

Treasure AI Voiceは、組織の録音、文字起こし、AI生成の要約、デバイスインベントリを自社のTreasure Data CDPデータベースに直接プッシュできます。データがCDPに取り込まれると、他の顧客データと結合してセグメントの作成やジャーニーの実行が可能になり、会議や通話で実際に話された内容を分析できます。

この連携はプッシュ型かつオンデマンドです。管理者がAI Voice Consoleからエクスポートを実行すると、Treasure AI Voiceが選択したデータのスナップショットを指定したテーブルにストリーミングします。管理すべき常設パイプラインはなく、データが中間の場所に保存されることもありません。APIキーはその1回の実行を認証するためだけに使用され、保存・永続化されることはありません。

各エクスポートは、CDPデータベース内の4つの論理テーブルに書き込みます。recordings、transcript_segments、summariesテーブルはその実行の対象範囲の録音を反映し、devicesテーブルは選択した日付範囲に関わらず常に組織の全デバイスインベントリを反映します。

録音は処理ステータスに関わらず含まれます。status列が各録音の状態を反映し、まだ文字起こしや要約が完了していない録音ではtranscription_text、summary_textおよび関連フィールドは空になります。

すべての行には、ソースレコードから導出された安定したuuidが付与されます。同じレコードは常に同じuuidにマッピングされるため、重複する日付範囲でエクスポートを再実行した後、uuidを基準に重複行を特定・削除できます。

すべての行にはtime列（Unixエポック秒）も付与され、Treasure Data CDPがネイティブの時間パーティショニングに使用します。これによりアナリストは時間で効率的にフィルタリングできます。time値は各テーブルで最も意味のあるタイムスタンプに紐付けられます — recordingsとsummariesはrecorded_at、セグメントは発話の開始、デバイスは最終ハートビート（報告がない場合はプロビジョニング時刻）です。

スキーマはTreasure AI Voiceが管理します。列は最初の書き込み時にCDPテーブルに追加されるため、事前に宣言する必要はありません。

エクスポートを実行する前に、以下を準備してください：

• Treasure AI Voiceのエンタープライズ管理者アカウント。
• 組織で連携が有効化されていること（下記参照）。
• 対象データベースに書き込める、IMPORTロールを持つTreasure Data CDP APIキー。
• Treasure Data CDP内の書き込み先データベース。エクスポートは、そのデータベース内で指定したテーブルに書き込み、最初の書き込み時にテーブルを作成します。

連携はデフォルトで無効です。有効にするには：

1. エンタープライズ管理者としてAI Voice Consoleにサインインします。
2. Exportページを開きます。
3. Treasure Data CDPを宛先として選択します。
4. Enable exportをクリックします。

有効化するオプションが表示されない場合は、Treasure AIの担当者までお問い合わせください。

1. ExportページでTreasure Data CDPを選択した状態で、以下を入力します：
   • API Key — Treasure Data CDP APIキー（IMPORTロール）。
   • Database — 書き込み先データベース名（例: ai_voice_export）。
2. （任意）Advancedを展開してカスタマイズします：
   • Recordings tableおよびTranscript segments tableの名前（デフォルト: recordings、transcript_segments）。
   • エクスポートする録音を絞り込むFrom / Toの日付範囲。範囲は各録音がキャプチャされた日時に適用され、Toの日付はその日の終わりまでを含みます。
3. Exportをクリックします。

AI Voice Consoleは、録音の読み取り、文字起こしデータの結合、Treasure Data CDPへのイベント送信の進捗を表示します。通常、実行は1分以内に完了します。

各実行は以下のいずれかの状態で完了します：

各エクスポート実行は — その結果と行数を含めて — TD_CDP_EXPORTイベントタイプとして監査ログに記録されます。APIキーが監査ログに書き込まれることはありません。

各テーブルはrecording_id（recordings.id）を共有しているため、CDP内で会議データの任意のビューを再構築できます。例：

• summariesをrecording_idでrecordingsに結合すると、要約と完全な録音メタデータを一緒に取得できます。
• transcript_segmentsをrecording_idでrecordingsに結合し、segment_indexで並べ替えると、会話を発話単位で再構築・分析できます。
• transcript_segmentsをspeaker_label（またはspeaker_id）でピボットすると、参加者ごとの発話時間を分析できます。
• recordingsをdevice_serial_number = serial_numberでdevicesに結合すると、会話をデバイスと割り当てられたユーザーに紐付けられます。

WITH ranked AS (
  SELECT *, ROW_NUMBER() OVER (PARTITION BY uuid ORDER BY time DESC) AS rn
  FROM your_table
)
SELECT * FROM ranked WHERE rn = 1