LiveRamp との統合

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

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

次の図は、Cortex Framework Data Foundation のマーケティング ワークロードを通じて LiveRamp データソースを利用できる仕組みを示しています。

LiveRamp データソース

図 1. LiveRamp データソース。

構成ファイル

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 を使用すると、企業は個人情報を個人にプログラムで解決できます。Cortex Framework は、API 呼び出しでハッシュ化された PII データを送信することで、LiveRamp のルックアップ エンドポイントを使用します。

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

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 Manager のドキュメントの手順をご覧ください。

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

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

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

Managed Airflow 接続

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

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

構成

config.ini ファイルは、Managed Airflow DAG の一部の動作と、LiveRamp API の使用方法を制御します。ニーズに基づいて LiveRamp/src/pipelines/config.ini ファイルを構成します。これらのパラメータはファイルですでに説明されていますが、liveramp_api_base_url に注意してください。このパラメータはデフォルトで LiveRamp の本番環境 API URL を指しますが、テスト目的で、設定によってはステージング バージョンを指すようにする必要がある場合があります。

次のステップ