Referências técnicas

Como trabalhar com atividades do Snowflake

Dica:

Esta página inclui algumas dicas que podem ser úteis ao trabalhar com atividades do Snowflake.

• Quando você espera que sua consulta resulte em um grande conjunto de linhas, sempre use LIMIT e OFFSET para paginar seus resultados. Consulte a documentação do Snowflake para obter exemplos de consulta para esse caso de uso.
• Gerar esquema de saída funciona com sucesso apenas para instruções de consulta que não contêm nenhuma variável de fluxo de trabalho. Depois que o esquema de saída for gerado, você pode substituir a consulta por variáveis. Recomendamos usar uma consulta que você possa executar com sucesso diretamente no Snowflake.
• Use Executar qualquer consulta de forma assíncrona para quaisquer consultas que demorem mais de 30 segundos para serem executadas.
• Você pode executar comandos que não são Select (como inserir, atualizar, procedimentos armazenados etc.) apenas com a atividade Execute Any Query Assíncrona .
• Use Obter Status de Execução de Consulta Assíncrona com o ID da consulta obtido da saída de Execute qualquer consulta de forma assíncrona.
• Você pode usar o gatilho de Status da consulta assíncrona alterado para iniciar um processo quando uma consulta for executada com sucesso ou encontrar um erro.
• Para obter os resultados de uma consulta assíncrona, use Obter status de execução de consulta assíncrona. Use o ID da consulta da saída da atividade Execute Any Query Assíncrona para gerar o esquema de saída. Depois que o esquema é gerado, você pode usar um ID de consulta variável. Alterar a entrada para uma variável não afeta as propriedades de saída, que permanecem as mesmas. Isso significa que a saída gerada não pode ser alterada a menos que você a regenere manualmente. Recomendamos configurar diferentes processos de fluxo de trabalho, se necessário. Se estiver usando o Studio Desktop, você poderá usar a atividade Native Search do pacote Snowflake versão 5.0.1.
• Para que os gatilhos Registro criado e Registro atualizado sejam executados com sucesso, você deve executar a seguinte consulta nas tabelas que você está monitorando em busca de eventos: ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE;. Além disso, certifique-se de ter as permissões necessárias configuradas no Snowflake.

Como identificar a saída da Chave Primária ao inserir uma linha no Snowflake

Se você tiver uma tabela com uma coluna ID que incrementa automaticamente, um caso de uso comum é inserir uma linha nessa tabela e gerar o ID da linha criada.

A solução mais simples para esse problema é manter uma relação de chave estrangeira na tabela em que você deseja descarregar seus dados. No exemplo abaixo, você pode descobrir que na atividade Snowflake Insert Record , mesmo que você tenha uma Saída SNOWFLAKE_ID, não há saída real durante a execução quando a linha é adicionada. Essa é uma limitação do Snowflake. Portanto, mantemos uma coluna de chave externa (SFDC_OPPORTUNITY_ID) para essa tabela.

Depois que a linha for adicionada, podemos usar a atividade de pesquisa Native do Snowflake para consultar a Chave Primária (SNOWFLAKE_ID) em troca da Chave Externa (SFDC_OPPORTUNITY_ID) e usando uma atividade do sistema Get Row Item subsequente.

O SNOWFLAKE_ID (Chave Primária) retornado também pode ser armazenado no aplicativo upstream em um campo personalizado (Salesforce neste caso), para que cada vez que uma atualização precise ser executada em uma linha, o ID não precisa ser consultado com Chave Eterna.