Snowflake Data Clean Rooms: アイデンティティとデータプロバイダーコネクタ¶

前提条件¶

1. Acxiomコネクタを構成する前に、ネイティブアプリのインストールについてAcxiomに問い合わせる必要があります。

2. クリーンルーム管理者がコネクタを構成する前に、Acxiomネイティブアプリの所有者は以下を行う必要があります。

   1. Snowsight にサインインします。

   2. Acxiomネイティブアプリの所有権を持つロールを想定します。たとえば、 acxiom_admin_role ロールがAcxiomネイティブアプリの所有者である場合、以下を実行します。

      USE ROLE acxiom_admin_role;
      

      Copy

   3. 以下のコマンドを実行して、Acxiom realid_app_role アプリケーションロールに Snowflake Data Clean Rooms アクセス権を付与します。

      GRANT APPLICATION ROLE <acxiom_app_database>.realid_app_role
        TO ROLE samooha_app_role;
      

      Copy

Acxiom Real ID コネクタを構成します。¶

Acxiom Real ID コネクタを構成するには:

1. クリーンルームUI へのサインイン。

2. 左側のナビゲーションで Connectors を選択します。

3. Identity & Data Providers タブを選択します。

4. Acxiom - Real ID を展開します。

5. Application Database フィールドに、Acxiomネイティブアプリによってインストールされたアプリケーションデータベースの名前を入力します。

6. Warehouse ドロップダウンリストで、ウェアハウスのサイズを選択します。弊社では、 DCR_WH_XLarge を推奨していますが、 Acxiomのウェアハウスのサイズとパフォーマンスに関するガイダンス をお読みください。Snowflake Data Clean Rooms で使用するウェアハウスの作成については、 別のウェアハウスの使用 をご覧ください。

7. Save を選択します。

前提条件¶

1. 前述の <label-cleanrooms_acxiom_real_id_connector> の説明に従って、Acxiom Real ID ネイティブアプリをインストールしている必要があります。

2. Acxiom Real ID トランスコーディングアプリケーションをインストールする必要があります。

3. Acxiom Real ID Transcoding ネイティブアプリをインストールした際に生成されたクライアント ID とクライアントシークレットを共同作業者に連絡して入手してください。

4. クリーンルーム管理者がコネクタを構成する前に、Acxiomネイティブアプリの所有者は以下を行う必要があります。

   1. Snowsight にサインインします。

   2. Acxiomネイティブアプリの所有権を持つロールを想定します。たとえば、 acxiom_admin_role ロールがAcxiomネイティブアプリの所有者である場合、以下を実行します。

      USE ROLE acxiom_admin_role;
      

      Copy

   3. 以下のコマンドを実行して、Acxiom realid_app_role アプリケーションロールに Snowflake Data Clean Rooms アクセス権を付与します。

      GRANT APPLICATION ROLE <acxiom_app_database>.realid_app_role TO ROLE samooha_app_role;
      

      Copy

Acxiom Real ID トランスコーディングコネクタの構成¶

Acxiom Real ID トランスコーディングコネクタを構成するには:

1. クリーンルームUI へのサインイン。

2. 左側のナビゲーションで Connectors を選択します。

3. Identity & Data Providers タブを選択します。

4. Acxiom Real ID Transcoding を展開します。

5. Application Database フィールドに、Acxiomネイティブアプリによってインストールされたアプリケーションデータベースの名前を入力します。

6. Client ID フィールドに、ネイティブアプリをインストールしたときにAcxiomから提供されたクライアント ID を入力します。

7. Client Secret フィールドに、ネイティブアプリをインストールしたときにAcxiomから提供されたクライアントシークレットを入力します。

8. Warehouse ドロップダウンリストで、ウェアハウスのサイズを選択します。弊社では、 DCR_WH_Medium を推奨していますが、 Acxiomのウェアハウスのサイズとパフォーマンスに関するガイダンス をお読みください。Snowflake Data Clean Rooms で使用するウェアハウスの作成については、 別のウェアハウスの使用 をご覧ください。

9. Acxiom Collaborator セクションで、 Acxiom Real ID Transcoding ネイティブアプリのインストール時に生成されたクライアント ID とクライアントシークレットとともに、1人以上のコラボレーターを選択します。コラボレーターがリストに表示されない場合、 クリーンルーム環境 に追加する必要があります。

10. Save を選択します。

ステップ1:Merkury Identityコネクタネイティブアプリのインストール¶

1. Merkury Identity Connectorネイティブアプリをインストールします。アカウントにリストを追加する場合は、Merkury (IDConnector@dentsu.com) までお問合せください。

2. SAMOOHA_APP_ROLE ロールに権限を付与します。

   1. Snowsightにサインインします 。

   2. Merkuryネイティブアプリの所有権を持つロールを引き受けます。たとえば、 ACCOUNTADMIN ロールがMerkuryネイティブアプリの所有者である場合、 USE ROLE ACCOUNTADMIN; を実行します

   3. 次のコマンドを実行して、Snowflake Data Clean RoomsにMerkury DCR_DB_ROLE アプリケーションロールへのアクセス権を付与します。

   GRANT APPLICATION ROLE <merkury_app_database>.DCR_DB_ROLE TO ROLE samooha_app_role;
   

   Copy

ステップ2:Merkury Identityコネクタネイティブアプリの構成¶

1. クリーンルームUI へのサインイン。

2. 左側のナビゲーションで Connectors を選択します。

3. Identity & Data Providers タブを選択します。

4. Merkury Identity Connector を展開します。

5. Application database フィールドに、Merkury Identityネイティブアプリによってインストールされたアプリケーションデータベースの名前を入力します。

6. 認証します。

TransUnion TruAudience ID用キャッシュ¶

Snowflakeは、 TransUnion コラボレーター IDs を、記録を一意に識別するソーステーブルの値にマップするキャッシュを維持します。例えば、キャッシュは各コラボレーターの ID をソーステーブルの user_id 列の値にマップするかもしれません。キャッシュは SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS テーブルに格納されます。このテーブルには次の列が含まれます。

列	データ型	説明
inputid	VARCHAR	統合中に Unique Record Column として選択された列の値。
collaborationid	VARCHAR	入力 ID とその他の統合パラメーターに基づいて生成された TransUnion コラボレーション ID。
lastprocessed	TIMESTAMP_NTZ	TransUnion がコラボレーション ID を生成したときのタイムスタンプ。

キャッシュに対して以下のアクションを実行できます：

キャッシュを削除する

TRUNCATE SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS;

Copy

キャッシュから特定の記録を削除する

カンマで区切られた一重引用符で囲まれた値のリストとして指定することで、キャッシュから特定の記録を削除することができます。例えば、 123456 と abcedf の入力 IDs を持つ記録を削除するには、以下を実行します。

DELETE FROM SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS
  WHERE inputid IN ('123456', 'abcedf');

Copy

別のデータセットの入力 IDs に基づいて複数の記録を削除する

入力 IDs が別のテーブルの列に存在する場合、キャッシュから複数の記録を削除することができます。例えば、削除する入力 IDs が my_db.my_schema.ref_table テーブルの user_id 列にリストされている場合、以下を実行します。

DELETE FROM SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS
  WHERE INPUTID IN (
    SELECT user_id as INPUTID
    FROM my_db.my_schema.ref_table
  );

Copy

バッチからすべての記録を追加する

TransUnion のビューに存在するバッチのすべての記録をキャッシュに追加することができます。

INSERT INTO SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS (
  INPUTID,
  COLLABORATIONID,
  LASTPROCESSED
SELECT
  INPUTID,
  COLLABORATIONID,
  LASTPROCESSED
FROM <TRANSUNION_APPLICATION_DATABASE>.SHARE_SCHEMA.REF_MATCHING_OUTPUT_VIEW
WHERE BATCHID = '<BATCH_ID>';

Copy

バッチからすべての記録をマージする

既存の入力 ID の記録を、対応する新しいコラボレーション IDs と新しい最終処理タイムスタンプで上書きすることで、 TransUnion のビューに存在するバッチのすべての記録をキャッシュにマージすることができます。

MERGE INTO SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS CT
USING <TRANSUNION_APPLICATION_DATABASE>.SHARE_SCHEMA.REF_MATCHING_OUTPUT_VIEW OT
  ON
    CT.INPUTID = OT.INPUTID
    AND OT.BATCHID = '<BATCH_ID>'
WHEN MATCHED THEN
  UPDATE SET
    CT.COLLABORATIONID = OT.COLLABORATIONID,
    CT.LASTPROCESSED = OT.LASTPROCESSED
WHEN NOT MATCHED THEN
  INSERT (
    INPUTID,
    COLLABORATIONID,
    LASTPROCESSED
  ) VALUES (
      OT.INPUTID,
      OT.COLLABORATIONID,
      OT.LASTPROCESSED
  );

Copy

入力 ID 記録にコラボレーター IDs を追加する

データセットの列として存在し、特定のバッチに存在する入力 ID 記録に対して、コラボレーター IDs を追加することができます。

INSERT INTO SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS (
  INPUTID,
  COLLABORATIONID,
  LASTPROCESSED
)
  SELECT
    INPUTID,
    COLLABORATIONID,
    LASTPROCESSED
  FROM <TRANSUNION_APPLICATION_DATABASE>.SHARE_SCHEMA.REF_MATCHING_OUTPUT_VIEW
  WHERE INPUTID IN (
    SELECT <column_name_containing_input_ids_to_be_added> as INPUTID
    FROM <dataset_fqtn_containing_input_ids_to_be_added>
    )
    AND BATCHID = '<BATCH_ID>';

Copy