Referências técnicas

Como trabalhar com atividades do Snowflake

Dica: esta página inclui algumas dicas que você pode achar úteis ao trabalhar com atividades do Snowflake.

• Quando você esperar que sua consulta resulte em um conjunto grande de linhas, sempre use LIMIT e OFFSET para paginar seus resultados. Consulte a documentação do Snowflake para ver 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 do fluxo de trabalho. Depois que o esquema de saída for gerado, você pode substituir a consulta por variáveis. Recomendamos o uso de uma consulta que você possa executar com sucesso no Snowflake diretamente.
• Use Executar qualquer consulta de forma assíncrona para qualquer consulta que leve mais de 30 segundos para ser executada.
• Você pode executar comandos nã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 Assíncrona.
• Você pode usar o gatilho de Status de consulta assíncrona alterado para iniciar um processo quando uma consulta tiver sido 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 qualquer consulta de forma assíncrona para gerar o esquema de saída. Depois que o esquema for 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 você estiver usando o Studio Desktop, você pode 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 um relacionamento de chave estrangeira na tabela na qual você deseja descarregar seus dados. No exemplo abaixo, você pode descobrir que, na atividade Insert Record do Snowflake, 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 é 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 usar uma atividade de 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.