Références techniques

Travailler avec des activités Snowflake

Astuce :

Cette page comprend 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 ensemble 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’activité Générer le 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 que vous pouvez exécuter avec succès directement dans Snowflake.
• Utilisez l’option Exécuter n’importe quelle requête de manière asynchrone pour toutes les requêtes dont l’exécution prend plus de 30 secondes.
• Vous pouvez exécuter des commandes hors sélection ( telles que l'insertion, la mise à jour, les procédures stockées, etc.) uniquement avec l'activité Exécuter la requête de manière asynchrone .
• Utilisez Obtenir le statut d’exécution de la requête asynchrone avec l’ID de requête obtenu à partir de la sortie de l’ activité Exécuter n’importe quelle requête de manière asynchrone.
• Vous pouvez utiliser le déclencheur Asynchrone Statut de la requête modifié 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. Utilisez l'ID de requête à la sortie de l' activité Exécuter n'importe quelle requête de manière asynchrone 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 changer 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 générez de nouveau manuellement. Nous vous recommandons de configurer différents processus de workflow si nécessaire. Si vous utilisez Studio Desktop, vous pouvez utiliser l'activité Native Search du package Snowflake version 5.0.1.
• Pour que les déclencheurs Enregistrement créé et Enregistrement mis à jour s'exécutent correctement, vous devez exécuter la requête suivante sur les tables que vous surveillez les événements : ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE;. De plus, assurez-vous que les autorisations requises sont 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 résoudre 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 pas de sortie réelle lors de l'exécution lorsque la ligne est ajoutée. Il s'agit d'une limitation de Snowflake. Par conséquent, nous conservons une colonne de clé externe (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é externe (SFDC_OPPORTUNITY_ID) et utiliser une activité système Get Row Item ultérieure.

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.