LiveRamp との連携

このページでは、Cortex Framework Data Foundation のマーケティング ワークロードのデータソースとして LiveRamp からデータを取得するために必要な構成について説明します。

LiveRamp は、企業がデータを接続、管理、有効化してカスタマー エクスペリエンスを向上させ、ビジネス成果を高めるのを支援するデータ コラボレーション プラットフォームです。Cortex Framework には、データを分析し、他のデータソースと組み合わせ、AI を使用してより深い分析情報を取得し、マーケティング戦略を最適化するためのツールとプラットフォームが用意されています。

次の図は、Cortex Framework Data Foundation のマーケティング ワークロードで LiveRamp データソースを利用できるようにする方法を示しています。

LiveRamp データソース

図 1LiveRamp データソース。

構成ファイル

config.json ファイルでは、さまざまなワークロードからデータを転送するためにデータソースに接続するために必要な設定を構成します。このファイルには、LiveRamp の次のパラメータが含まれています。

   "marketing": {
        "deployLiveRamp": true,
        "LiveRamp": {
            "datasets": {
                "cdc": ""
            }
        }
    }

次の表に、各 LiveRamp パラメータの値を示します。

パラメータ 意味 デフォルト値 説明
marketing.LiveRamp LiveRamp をデプロイする true LiveRamp データソースのデプロイを実行します。
marketing.LiveRamp.datasets.cdc LiveRamp の CDC データセット LiveRamp 用の CDC データセット。

API 接続

Cortex Framework Data Foundation は、LiveRamp と統合することで ID 解決を可能にします。Cortex Framework は RampID ルックアップを実行できるため、企業は CRM システムから既知のオーディエンスや顧客セグメントを特定できます。

RampID は、メールアドレス、電話番号、名前などの個人情報（PII）を使用して LiveRamp の API によって生成される識別子です。この RampID により、企業は複数のシステム（異なるキャンペーンのオーディエンスなど）にわたるレコードを特定して統合できます。LiveRamp と統合することで、オーディエンスの特定とターゲティングの精度を高め、より効果的でパーソナライズされたマーケティング キャンペーンを実施できます。

LiveRamp Identity Resolution Retrieval API を使用すると、企業はプログラマティックに個人の PII データを解決できます。Cortex Framework は、API 呼び出しを介してハッシュ化された PII データを送信することで、LiveRamp のLookup Endpoint を使用します。

入力テーブルと出力テーブル

Cortex Framework をデプロイすると、config.json で指定された関連データセットに次の 2 つの BigQuery テーブルが作成されます。

rampid_lookup_input 個のテーブル

rampid_lookup_input テーブルは、RampID ルックアップ プロセスの入力です。

列 Data Type 説明 例 主キー
id STRING このレコードの一意の ID。 「123」 はい
segment_name STRING オーディエンス/CRM/顧客セグメントの名前。 「高価値」 ×
source_system_name STRING レコードの送信元となるソースシステム。 「Salesforce」 ×
name STRING お客様の名前 「John Doe」 ×
email STRING お客様のメールアドレス 「example@example.com」 ×
phone_number STRING お客様の電話番号 「1234567890」 ×
postal_code STRING お客様の郵便番号 "12345" ×
is_processed BOOL レコードがすでに処理されているかどうかを示します。

新しいレコードの場合は、FALSE を入力します。

処理が完了すると、システムによって TRUE に更新されます。 		FALSE ×
load_timestamp TIMESTAMP レコードがシステムに挿入されたときのタイムスタンプ。これは純粋に監査目的です。 「2020-01-01 00:00:00 UTC」 ×
processed_timestamp TIMESTAMP システムがこのレコードの API ルックアップを実行したとき刻。これは常にシステムによって入力されます。 「2020-01-01 00:00:00 UTC」 ×

rampid_lookup_input テーブルには、お客様の PII の詳細（以下に例を示します）を定期的に（ビジネスニーズに基づいて）入力する必要があります。Cortex Framework には、このテーブルにデータを自動的に入力する方法はありませんが、Cortex Framework ですでにデプロイされている Salesforce システムのデータを使用してこのテーブルにデータを入力する方法を示したサンプル スクリプト ddls/samples/populate_rampid_lookup_input.sql が用意されています。データが別のシステムから取得される場合は、このファイルをガイドとして使用できます。

rampid_lookup_input テーブルに重複するエントリがないことを確認します（たとえば、ID が異なる場合でも、同じ個人が同じ PII 情報で複数回存在するなど）。セグメントに重複するエントリが多数含まれていると、Cortex Framework Lookup DAG は失敗します。これは LiveRamp API によって適用されます。

rampid_lookup テーブル

rampid_lookup テーブルは、入力レコード内の各セグメントの RampID を含む出力テーブルです。LiveRamp は、設計上、RampID を個々のレコードにマッピングできません。

列 Data Type 説明
segment_name STRING 入力テーブルのセグメント名。
ramp_id STRING LiveRamp RampID
記録スタンプ TIMESTAMP この RampID ルックアップが実行されたときのタイムスタンプ。

同じ個人の LiveRamp RampID は時間の経過とともに変更される可能性があります。つまり、すでに処理済みのデータに対して、新しいルックアップを定期的に行う必要があります。Cortex Framework には、セグメント レベルでこれを行う方法を示すサンプル スクリプト ddls/samples/clean_up_segment_matching.sql が用意されています。これにより、セグメント全体をリセットできます。システムは、そのセグメントのルックアップを実行し、最新の RampID を返します。

rampid_lookup（出力テーブル）には、入力テーブルと比較してレコード数が若干少ない場合があります。これは、Cortex Framework が PII の詳細を使用して入力レコードをデバッグし、LiveRamp API の検索が失敗しないようにするため、設計上の仕様です。

アカウント認証

  1. 認証情報を取得するには、LiveRamp にお問い合わせください。これには、クライアント ID とクライアント シークレットが含まれます。

  2. Secret Manager を使用して cortex-framework-liveramp という名前の Secret を作成し、次の値を使用します。Secret-Manager のドキュメントの手順をご覧ください。

    {
  'client_id':'CLIENT_ID',
  'client_secret':'CLIENT_SECRET',
  'grant_type':'client_credentials'
}

    次のように置き換えます。

    • CLIENT_ID は、手順 1 で取得したクライアント ID に置き換えます。
    • CLIENT_SECRET は、ステップ 1 で取得したクライアント シークレットに置き換えます。

Cloud Composer 接続

Cloud Composer で次の接続を作成します。詳細については、Airflow 接続を管理するドキュメントをご覧ください。

接続名 目的
liveramp_cdc_bq LiveRamp API > CDC データセットの転送の場合

構成

config.ini ファイルは、Cloud Composer DAG の動作の一部と、LiveRamp API の使用方法を制御します。必要に応じて LiveRamp/src/pipelines/config.ini ファイルを構成します。これらのパラメータはファイルにすでに記述されていますが、liveramp_api_base_url に注意してください。このパラメータはデフォルトで LiveRamp の本番環境 API URL を参照しますが、テスト目的では、設定に応じてステージング バージョンを参照する必要があります。

次のステップ