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
言語: 日本語