Integración Snowflake n8nAutomatiza Snowflake con n8n.
Tu almacén de datos vale para mucho más que alimentar cuadros de mando. La integración Snowflake n8n abre una conexión directa a tu cuenta y expone 3 operaciones: ejecutar SQL, insertar filas y actualizar filas. Snowflake no trae trigger, así que el flujo arranca en otro sitio.
Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth
¿Qué te aporta de verdad la integración Snowflake n8n?
La integración Snowflake n8n son dos piezas: el nodo Snowflake que viene con n8n y un credential, o sea un acceso guardado una sola vez, que entra en tu cuenta fijando base, almacén, esquema y rol. Con las dos listas, cualquier flujo lee una tabla o escribe en ella a mitad de camino. El nodo habla SQL sobre una conexión viva y cubre el terreno con 3 operaciones.
El primer uso es el informe recurrente. Un Schedule Trigger, el nodo que dispara el flujo cada cierto intervalo, lanza Execute Query sobre los pedidos de ayer y las filas siguen hacia Google Sheets para el equipo financiero o hacia un canal de Slack en forma de resumen corto. Nadie vuelve a abrir un cliente SQL a primera hora.
El segundo va en dirección contraria. Un alta de formulario, un cobro, una ficha creada en Supabase: todo eso aterriza en una tabla intermedia con Insert, una fila por item, antes de la transformación que ya tienes montada. El tercero cierra el círculo. Cuando el correo de seguimiento ha salido, Update marca esas mismas filas como tratadas y la ejecución siguiente las salta.
Conviene dejar clara una cosa. Este credential abre una conexión Snowflake, la misma que haría un cliente SQL, y no una sesión de API HTTP. La salida habitual de llamar a un endpoint REST con el nodo HTTP Request no aplica aquí, porque no hay endpoint esperándote. La salida es Execute Query: lo que el nodo no expone como operación dedicada, un cruce entre esquemas, un MERGE, una tabla temporal, lo escribes en SQL y lo ejecutas. Es una puerta más ancha de lo normal, no más estrecha.
Y los límites. No hay trigger de Snowflake, así que nada reacciona por su cuenta a un cambio dentro del almacén. Insert y Update piden una lista de columnas separadas por comas en vez de un selector de campos, de modo que una errata aparece al ejecutar y no al montar el flujo. Una consulta que devuelve cien mil filas se convierte en cien mil items dentro de n8n: filtra en SQL, no después. Si vienes de Postgres el nodo te sonará, y el Curso n8n repasa credentials y expresiones antes de tocar datos de producción.
¿Cómo conectas Snowflake con n8n?
- 01
Rellena los campos comunes del credential
En n8n abre el menú Credentials y crea un credential de Snowflake. Account es la cadena que va entre
https://ysnowflakecomputing.comen tu URL de Snowflake: si la URL eshttps://abc.eu-central-1.snowflakecomputing.com, el valor esabc.eu-central-1. Después indica la Database a la que conectar, el Warehouse que n8n usa para consultar y cargar datos, el Schema activo tras la conexión y el Role de la sesión. - 02
Elige contraseña o par de claves
Hay dos métodos de autenticación. Con contraseña añades un Username y un Password a los campos comunes. Con par de claves, n8n pide el Username que tiene asignada la clave pública y una Private Key en formato PEM, PKCS#8, pegada entera con sus delimitadores
-----BEGIN PRIVATE KEY-----y-----END PRIVATE KEY-----. La Passphrase solo hace falta si esa clave está cifrada. - 03
Engancha el credential y prueba una consulta
Coloca un nodo Snowflake en un flujo y elige el credential en su desplegable. Se crea una vez y se reutiliza en todas partes, así que los siguientes flujos apuntan a la misma entrada. Deja la primera prueba en Execute Query con algo inofensivo, un
SELECTsobre una tabla pequeña, y comprueba que las filas vuelven como items. Si el rol o el almacén están mal elegidos, lo ves ahí mismo.
Qué sabe hacer el nodo Snowflake
El nodo Snowflake expone 3 operaciones. Para cada una: el nodo tal como lo configuras en n8n, los campos obligatorios y nuestras notas de campo.
Execute a SQL query
executeQueryLo que ves en n8n
Notas y casos de uso
Ejecuta cualquier instrucción SQL sobre la base y el almacén fijados en el credential y devuelve cada fila del resultado como un item de n8n.
Parámetros clave
- Query: la consulta a lanzar, por ejemplo
SELECT id, name FROM product WHERE id < 40. Los marcadores$1,$2señalan dónde entran los valores. - Query Parameters: los valores ligados a esos marcadores, separados por comas, fijos o en expresión como
{{ $json.email }}, {{ $json.status }}. n8n los sanea, y eso impide que una entrada externa acabe en inyección SQL.
Insert rows in database
insertLo que ves en n8n
Notas y casos de uso
Escribe los items entrantes en una tabla como filas nuevas, una fila por item, sin tocar lo que ya está guardado.
Parámetros clave
- Table: el nombre de la tabla que recibe los datos, escrito igual que en la base conectada. Una expresión como
{{ $json.target_table }}sirve cuando un nodo anterior decide el destino. - Columns: la lista de propiedades del item que hacen de columnas, separadas por comas, del estilo
id,name,description. Una propiedad fuera de esa lista nunca llega a la tabla, aunque viaje dentro del item.
Update rows in database
updateLo que ves en n8n
Notas y casos de uso
Empareja cada item entrante con filas que ya existen y reescribe solo las columnas que enumeras.
Parámetros clave
- Table: el nombre de la tabla cuyas filas hay que modificar.
- Update Key: el nombre de la propiedad que decide qué filas cambian, normalmente
id. El valor viaja con el item, así que un item sin esa propiedad no actualiza nada. - Columns: las propiedades a escribir, separadas por comas, por ejemplo
name,description, con solo aquello que deba moverse.
¿Necesitas ayuda para automatizar Snowflake con n8n?
El equipo te responde directamente.
Cada mensaje lo lee una persona.
