Cache para TransUnion TruAudience Identity¶
O Snowflake mantém um cache que mapeia IDs do colaborador TransUnion para valores na tabela de origem que identificam exclusivamente os registros. Por exemplo, o cache pode mapear cada ID do colaborador para um valor na coluna user_id
da tabela de origem. O cache é armazenado na tabela SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS
.
Esta tabela contém as seguintes colunas:
Coluna
Tipo de dados
Descrição
inputid
VARCHAR
Valor da coluna selecionada como Unique Record Column durante a integração.
collaborationid
VARCHAR
ID da colaboração do TransUnion gerada com base no ID de entrada e outros parâmetros de integração.
lastprocessed
TIMESTAMP_NTZ
Carimbo de data/hora em que TransUnion gerou o ID da colaboração.
Você pode executar as seguintes ações para trabalhar com o cache:
- Apagar o cache
TRUNCATE SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS;
- Excluir registros específicos do cache
Você pode excluir registros específicos do cache especificando-os como uma lista separada por vírgulas de valores entre aspas simples. Por exemplo, para excluir os registros com IDs de entrada de
123456
eabcedf
, execute:DELETE FROM SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.SAMOOHA_INTERNAL_TRANSUNION_ID_GENERATION_RECORDS WHERE inputid IN ('123456', 'abcedf');
- Excluir vários registros com base em IDs de entrada em um conjunto de dados separado
Você pode excluir vários registros do cache quando IDs da entrada estiverem presentes em uma coluna de outra tabela. Por exemplo, se os IDs de entrada a serem excluídos estiverem listados na coluna
user_id
da tabelamy_db.my_schema.ref_table
, execute: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 );
- Adição de todos os registros de um lote
Você pode adicionar todos os registros de um lote que está presente na exibição do TransUnion ao 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>';
- Mescla de todos os registros de um lote
Você pode mesclar todos os registros de um lote que está presente na exibição do TransUnion no cache, substituindo os registros de ID de entrada existentes pelos novos IDs de colaboração correspondente e pelos novos carimbos de data/hora do último processamento.
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 );
- Adição de IDs do colaborador para registros de ID de entrada
Você pode adicionar IDs do colaborador para registros de ID de entrada presentes como uma coluna em um conjunto de dados e também presentes em um lote específico.
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>';