Ressources · Intégration n8n

Intégration Snowflake n8nAutomatiser Snowflake avec n8n.

Ton entrepôt de données sert à autre chose qu'alimenter des tableaux de bord. L'intégration Snowflake n8n ouvre une connexion directe à ton compte et expose 3 opérations : exécuter du SQL, insérer des lignes, mettre à jour des lignes. Aucun trigger n'existe côté Snowflake, le workflow démarre donc ailleurs.

Tester l'intégration Snowflake sur n8nVoir les 3 opérations

Avis vérifiés sur Trustpilot · Agence IA, automatisation & growth

Pourquoi automatiser

À quoi sert vraiment l'intégration Snowflake n8n ?

L'intégration Snowflake n8n, c'est le nœud Snowflake livré avec n8n et un credential, c'est-à-dire un accès enregistré une fois pour toutes, qui se connecte à ton compte en fixant une base, un entrepôt, un schéma et un rôle. Les deux en place, n'importe quel workflow lit une table ou y écrit en cours de route. Le nœud parle SQL sur une connexion vivante, et 3 opérations couvrent le terrain.

Le premier usage, c'est la remontée de chiffres. Un Schedule Trigger, le nœud qui déclenche un workflow à intervalle fixe, lance Execute Query sur les commandes de la veille, et les lignes partent vers Google Sheets pour la compta ou vers un canal Slack sous forme de résumé. Plus personne n'ouvre un client SQL le matin.

Le deuxième va dans l'autre sens. Une inscription à un formulaire, un paiement, une fiche créée dans Airtable : tout ça atterrit dans une table tampon via Insert, une ligne par item, avant la transformation que tu fais déjà tourner. Le troisième referme la boucle. Une fois la relance envoyée, Update marque ces mêmes lignes comme traitées, et l'exécution suivante les ignore.

Un point mérite d'être posé clairement. Ce credential ouvre une connexion Snowflake, celle que ferait un client SQL, pas une session d'API HTTP. Le repli habituel qui consiste à appeler un endpoint REST avec le nœud HTTP Request ne s'applique donc pas ici : il n'y a pas d'endpoint qui t'attend. Le repli, c'est Execute Query. Tout ce que le nœud n'expose pas en opération dédiée, une jointure entre schémas, un MERGE, une table temporaire, s'écrit en SQL et s'exécute. C'est une porte plus large que la moyenne, pas plus étroite.

Les limites, maintenant. Pas de trigger Snowflake, donc rien ne réagit tout seul à un changement dans l'entrepôt. Insert et Update attendent une liste de colonnes séparées par des virgules plutôt qu'un sélecteur de champs, et une faute de frappe se voit à l'exécution, pas pendant la construction. Une requête qui ramène cent mille lignes produit cent mille items dans n8n : filtre en SQL, pas après. Si tu viens de Postgres, le nœud te paraîtra familier, et la Formation n8n reprend credentials et expressions avant de toucher aux données de production.

Connexion

Comment connecter Snowflake à n8n ?

  1. 01

    Renseigner les champs communs du credential

    Dans n8n, ouvre le menu Credentials et crée un credential Snowflake. Account correspond à la chaîne située entre https:// et snowflakecomputing.com dans ton URL Snowflake : pour https://abc.eu-central-1.snowflakecomputing.com, c'est abc.eu-central-1. Indique ensuite la Database visée, le Warehouse que n8n utilisera pour exécuter les requêtes et charger les données, le Schema actif après connexion et le Role de la session.

  2. 02

    Choisir mot de passe ou paire de clés

    Deux méthodes d'authentification existent. Par mot de passe, tu ajoutes un Username et un Password aux champs communs. Par paire de clés, n8n demande le Username auquel la clé publique est rattachée et une Private Key au format PEM, PKCS#8, collée en entier avec ses délimiteurs -----BEGIN PRIVATE KEY----- et -----END PRIVATE KEY-----. La Passphrase ne sert que si cette clé est chiffrée.

  3. 03

    Rattacher le credential et tester une requête

    Pose un nœud Snowflake dans un workflow et sélectionne le credential dans sa liste déroulante. Il se crée une fois et se réutilise partout, les workflows suivants pointeront sur la même entrée. Garde Execute Query pour le premier essai avec quelque chose d'inoffensif, un SELECT sur une petite table, et vérifie que les lignes reviennent bien sous forme d'items. Un rôle ou un entrepôt mal choisi se voit tout de suite.

Actions

Ce que sait faire le nœud Snowflake

Le nœud Snowflake expose 3 opérations. Pour chacune : le nœud tel que tu le configures dans n8n, les champs obligatoires, et nos notes de terrain.

01

Execute a SQL query

executeQuery

Ce que tu vois dans n8n

Notes & cas d'usage

Exécute n'importe quelle instruction SQL sur la base et l'entrepôt fixés dans le credential, et renvoie chaque ligne de résultat comme un item n8n.

Paramètres clés

  • Query : la requête à lancer, par exemple SELECT id, name FROM product WHERE id < 40. Les marqueurs $1, $2 indiquent où les valeurs seront injectées.
  • Query Parameters : les valeurs liées à ces marqueurs, séparées par des virgules, fixes ou en expression comme {{ $json.email }}, {{ $json.status }}. n8n les nettoie, ce qui évite qu'une saisie externe se transforme en injection SQL.
Cas d'usage
sortir le chiffre d'affaires de la veille pour un résumé, ou vérifier qu'une fiche client existe avant d'orienter la suite du workflow.
02

Insert rows in database

insert

Ce que tu vois dans n8n

Notes & cas d'usage

Écrit les items entrants dans une table sous forme de nouvelles lignes, une ligne par item, sans toucher à l'existant.

Paramètres clés

  • Table : le nom de la table qui reçoit les données, orthographié comme dans la base connectée. Une expression du type {{ $json.target_table }} fonctionne si un nœud précédent choisit la destination.
  • Columns : la liste des propriétés de l'item utilisées comme colonnes, séparées par des virgules, du genre id,name,description. Une propriété absente de cette liste n'arrive jamais dans la table, même présente dans l'item.
Cas d'usage
stocker les inscriptions brutes dans une table tampon avant que la transformation de nuit les reprenne.
03

Update rows in database

update

Ce que tu vois dans n8n

Notes & cas d'usage

Rapproche chaque item entrant des lignes déjà présentes et ne réécrit que les colonnes listées.

Paramètres clés

  • Table : le nom de la table dont les lignes doivent changer.
  • Update Key : le nom de la propriété qui décide quelles lignes sont concernées, en général id. La valeur voyage avec l'item, donc un item sans cette propriété ne met rien à jour.
  • Columns : les propriétés à écrire, séparées par des virgules, par exemple name,description, en n'y mettant que ce qui doit bouger.
Cas d'usage
marquer un lot de lignes comme traité une fois les relances parties, pour que l'exécution suivante les laisse de côté.
Besoin d'aide

Besoin d'aide pour automatiser Snowflake avec n8n ?

L'équipe te répond directement.

Chaque message est lu par une personne.

FAQ

Snowflake et n8n, les questions qui suivent

01L'intégration Snowflake n8n est-elle gratuite ?
Côté n8n, oui. Le nœud Snowflake est livré avec n8n : rien à installer, aucun module à acheter, et le comportement est identique sur n8n Cloud, l'offre hébergée par n8n, et sur une instance que tu héberges toi-même via Docker ou npm en Community Edition, sous licence Sustainable Use. Un workflow construit d'un côté tourne de l'autre sans retouche. Ce que coûte ton compte Snowflake lui-même est une affaire entre Snowflake et toi, et cette page ne traite pas ce sujet. Le temps d'entrepôt consommé par tes requêtes se budgète comme pour n'importe quel autre client connecté.
02Quels credentials faut-il pour le nœud Snowflake ?
Un seul credential Snowflake, créé une fois dans n8n et réutilisé par tous les workflows. Les deux méthodes partagent les mêmes champs communs : Account, la portion de ton URL Snowflake située entre https:// et snowflakecomputing.com, puis Database, Warehouse, Schema, Role et l'interrupteur Client Session Keep Alive. L'authentification par mot de passe ajoute un Username et un Password. L'authentification par paire de clés demande à la place le Username porteur de la clé publique et une Private Key au format PEM, PKCS#8, collée avec ses délimiteurs BEGIN et END, plus une Passphrase si la clé est chiffrée. Donne au rôle les droits strictement utiles.
03Quelles sont les limites du nœud Snowflake dans n8n ?
Trois points. D'abord le nœud expose 3 opérations, donc tout ce qui dépasse l'insertion et la mise à jour de lignes s'écrit en SQL. Ensuite ce repli s'appelle Execute Query, et surtout pas le nœud HTTP Request : le credential ouvre une connexion à l'entrepôt, pas une session HTTP, il n'y a donc aucun endpoint REST à appeler depuis n8n ici. Execute Query accepte n'importe quelle instruction, jointures, fusions et créations de table comprises. Enfin Insert et Update fonctionnent avec une liste de colonnes séparées par des virgules : les noms sont validés à l'exécution, pas au moment où tu construis.
04n8n peut-il réagir en temps réel à Snowflake ?
Non, et mieux vaut le savoir avant de dessiner le workflow. Snowflake n'a pas de nœud trigger dans n8n, rien ne surveille donc l'entrepôt à la recherche de lignes nouvelles ou modifiées. Un workflow qui touche Snowflake démarre ailleurs : un Schedule Trigger à intervalle fixe, un nœud Webhook de n8n appelé par un service tiers, c'est-à-dire une URL n8n que ce service contacte quand il se passe quelque chose, ou le trigger d'un autre outil. Le schéma le plus courant reste une planification, un Execute Query sur une colonne marqueur, puis un Update qui tamponne les lignes traitées.
05n8n ou Make pour automatiser Snowflake ?
Ça dépend surtout de l'endroit où tes données ont le droit de passer. Make est une plateforme hébergée, sans auto-hébergement possible, facturée à l'opération : un export nocturne qui remonte des milliers de lignes se traduit en milliers d'opérations facturées. n8n tourne sur n8n Cloud ou sur ton propre serveur, ce qui compte quand un extrait d'entrepôt ne doit pas sortir du réseau, et son modèle de coût ne suit pas le nombre de lignes de la même façon. Make garde l'avantage d'un éditeur visuel que certaines équipes lisent plus vite. Pour du SQL planifié et des écritures en retour, n8n auto-hébergé reste le choix tranquille.
Même plateforme

Autres docs utiles sur ce stack.

Voir toutes les intégrations