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

캐시에서 특정 레코드 삭제

작은따옴표로 묶은 값을 쉼표로 구분한 목록으로 지정하여 캐시에서 특정 레코드를 삭제할 수 있습니다. 예를 들어, 입력 IDs가 123456 및 abcedf 인 레코드를 삭제하려면 다음을 실행합니다.

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

배치의 모든 레코드 병합

TransUnion의 뷰에 있는 배치의 모든 레코드를 기존 입력 ID 레코드를 해당되는 새 협업 IDs와 마지막으로 처리된 새 타임스탬프로 덮어쓰면 캐시에 병합할 수 있습니다.

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