Cache pour identité TransUnion TruAudience¶

Snowflake maintient un cache qui mappe les IDs du collaborateur TransUnion aux valeurs de la table source qui identifient de manière unique les enregistrements. Par exemple, le cache peut mapper chaque ID de collaborateur à une valeur dans la colonne user_id de la table source. Le cache est stocké dans la table SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS.

Cette table contient les colonnes suivantes :

Colonne	Type de données	Description
inputid	VARCHAR	Valeur de la colonne sélectionnée comme Unique Record Column pendant l’intégration.
collaborationid	VARCHAR	ID de collaboration TransUnion généré sur la base de l’ID d’entrée et d’autres paramètres d’intégration.
lastprocessed	TIMESTAMP_NTZ	Horodatage lorsque TransUnion a généré l” ID de collaboration.

Vous pouvez effectuer les actions suivantes pour utiliser le cache :

Supprimer le cache

TRUNCATE SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS;

Copy

Supprimer des enregistrements spécifiques du cache

Vous pouvez supprimer des enregistrements spécifiques du cache en les spécifiant sous la forme d’une liste de valeurs séparées par des virgules entre guillemets simples. Par exemple, pour supprimer les enregistrements avec les IDs d’entrée de 123456 et abcedf, exécutez :

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

Copy

Supprimer plusieurs enregistrements en fonction des IDs d’entrée dans un ensemble de données distinct

Vous pouvez supprimer plusieurs enregistrements du cache lorsque les IDs d’entrée sont présents dans une colonne d’une autre table. Par exemple, si les IDs d’entrée à supprimer sont répertoriés dans la colonne user_id de la table my_db.my_schema.ref_table, exécutez :

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

Ajouter tous les enregistrements d’un lot

Vous pouvez ajouter tous les enregistrements d’un lot présent dans la vue de TransUnion sur le cache.

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

Fusionner tous les enregistrements d’un lot

Vous pouvez fusionner tous les enregistrements d’un lot présent dans la vue de TransUnion sur le cache en écrasant les enregistrements d’ID d’entrée existants avec les nouveaux IDs de collaboration correspondants et les nouveaux horodatages de dernier traitement.

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

Ajouter des IDs de collaborateur pour les enregistrements des ID d’entrée

Vous pouvez ajouter des IDs de collaborateur pour les enregistrements d’ID d’entrée présents sous forme de colonne dans un ensemble de données et également présents dans un lot spécifique.

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