Références techniques

Travailler avec des activités Snowflake

Astuce : cette page contient quelques conseils qui peuvent vous être utiles lorsque vous travaillez avec les activités Snowflake.

• Lorsque vous vous attendez à ce que votre requête génère un grand nombre de lignes, utilisez toujours LIMIT et OFFSET pour paginer vos résultats. Reportez-vous à la documentation de Snowflake pour obtenir des exemples de requête pour ce cas d'utilisation.
• L'option Générer un schéma de sortie ne fonctionne correctement que pour les instructions de requête qui ne contiennent aucune variable de workflow. Une fois le schéma de sortie généré, vous pouvez remplacer la requête par des variables. Nous vous recommandons d’utiliser une requête pouvant être exécutée directement dans Snowflake.
• Utilisez Exécuter toute requête de manière asynchrone (Execute any Query Asynchronically) pour toutes les requêtes dont l'exécution prend plus de 30 secondes.
• Vous pouvez exécuter des commandes non-sélection (telles que l'insertion, la mise à jour, les procédures stockées, etc.) uniquement avec l'activité Exécuter toute requête de manière asynchrone (Execute any Query Asynchronously ).
• Utilisez Obtenir le statut d'exécution de la requête asynchrone (Get Asynchronous Query Execution Status) avec l'ID de requête obtenu à partir de la sortie de l'activité Exécuter toute requête de manière asynchrone (Execute any Query Asynchronously).
• Vous pouvez utiliser le déclencheur Asynchrone Statut de requête modifié (Asynchronous Query Status Changed) pour lancer un processus lorsqu'une requête a été exécutée avec succès ou a rencontré une erreur.
• Pour obtenir les résultats d'une requête asynchrone, utilisez Obtenir le statut d'exécution de la requête asynchrone (Get Asynchronous Query Execution Status). Utilisez l'ID de requête de la sortie de l'activité Exécuter toute requête de manière asynchrone (Execute any Query Asynchronically) pour générer le schéma de sortie. Une fois le schéma généré, vous pouvez utiliser un ID de requête variable. Le fait de modifier l’entrée en variable n’affecte pas les propriétés de sortie, qui restent les mêmes. Cela signifie que la sortie générée ne peut pas être modifiée, sauf si vous la régénérez manuellement. Nous vous recommandons de configurer différents processus de workflow si nécessaire. Si vous utilisez Studio Desktop, vous pouvez utiliser l'activité Recherche native (Native Search ) du package Snowflake version 5.0.1.
• Pour que les déclencheurs Enregistrement créé ( Record Created ) et Enregistrement mis à jour ( Record Updated ) s'exécutent correctement, vous devez exécuter la requête suivante sur les tables dont vous surveillez les événements : ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE;. De plus, assurez-vous d'avoir les autorisations requises configurées dans Snowflake.

Identifier la sortie de la clé primaire lors de l’insertion d’une ligne dans Snowflake

Si vous avez une table avec une colonne d'ID à incrémentation automatique, un cas d'utilisation courant consiste à vouloir insérer une ligne dans cette table et à sortir l'ID de la ligne créée.

La solution la plus simple pour contourner ce problème consiste à maintenir une relation de clé externe dans la table où vous souhaitez décharger vos données. Dans l'exemple ci-dessous, vous pouvez constater que dans l'activité Snowflake Insert Record , même si vous avez une Sortie SNOWFLAKE_ID, il n'y a aucune sortie réelle pendant l'exécution lorsque la ligne est ajoutée. Il s'agit d'une limitation de Snowflake. Par conséquent, nous conservons une colonne Clé externe (External Key Column) (SFDC_OPPORTUNITY_ID) pour cette table.

Une fois la ligne ajoutée, nous pouvons utiliser l’activité de recherche Snowflake Native pour interroger la clé primaire (SNOWFLAKE_ID) en échange de la clé étrangère (SFDC_OPPORTUNITY_ID) et en utilisant une activité système ultérieure Get Row Item .

Le SNOWFLAKE_ID renvoyé (clé primaire) peut également être stocké dans l'application en amont dans un champ personnalisé (Salesforce dans ce cas), de sorte que chaque fois qu'une mise à jour doit être effectuée de suite, il n'est pas nécessaire d'interroger l'ID avec la clé étrangère.