Integración CrateDB n8nAutomatiza CrateDB con n8n.
Tres operaciones y una conexión directa a la base. Eso es la integración CrateDB n8n: Execute Query lanza la consulta que escribas, Insert añade filas, Update reescribe las que ya están guardadas. No existe un trigger de CrateDB, así que el flujo de trabajo arranca desde otro nodo.
Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth
¿Qué resuelve la integración CrateDB n8n?
El nodo CrateDB abre una conversación en SQL entre un flujo de trabajo de n8n y tu clúster. Un recurso, 3 operaciones y una credencial (el acceso que se guarda una sola vez en n8n) que describe una base de datos: host, puerto y nombre de base. No hay clave de API web por medio. De ahí sale la forma del nodo y buena parte de lo que puedes esperar de él.
Conviene empezar por ahí, porque cambia el reflejo habitual. La credencial de CrateDB abre una conexión a la base, no una API HTTP, así que el nodo HTTP Request no es el plan B que sería con un servicio web. El plan B aquí se llama Execute Query y acepta cualquier consulta SQL. Por eso bastan 3 operaciones donde un nodo de aplicación web necesita una lista larga.
Con eso claro, mira Update, la operación que más se usa cuando los datos ya existen. Update Key nombra la propiedad que decide qué filas se actualizan, normalmente id, y Columns nombra lo que se reescribe, por ejemplo name,description. Los valores siguen viniendo del item, con una expresión como {{ $json.price }}. Un catálogo de productos cuyos precios se mueven cada mañana vive entero en esa operación.
Insert cubre el movimiento contrario: alimentar la tabla. Schema y Table dicen dónde, y Columns dice qué. Ahí listas las propiedades del item entrante, id,name,description, y cada una cae en la columna del mismo nombre. El tipo de columna se declara en ese mismo campo, pegando :type al nombre, como en id:int,name:text. Si vienes de MySQL o de MongoDB, ese detalle es el que más se olvida.
Queda la lectura, y con ella el hábito que más ordena un flujo: pon quantity,price en Query Parameters, escribe quantity > $1 en la Query, y los valores viajan al lado del SQL en vez de quedar pegados dentro. Las filas vuelven como items, listas para un mensaje en Slack o para el siguiente nodo.
Dos plantillas de la comunidad enseñan el conjunto mejor que cualquier descripción: el flujo 597 crea una tabla en CrateDB e inserta datos, y el flujo 609 gestiona el seguimiento de incidencias entre PagerDuty y CrateDB. Ábrelas junto al nodo y los nombres de campo dejan de ser abstractos. Si dudas antes de montar todo esto, la Reseña n8n y el Curso n8n están para eso.
¿Cómo se conecta CrateDB con n8n?
- 01
Reúne los datos del clúster
Abre el menú Credentials de n8n y crea una credencial de CrateDB. Tres campos indican adónde llamar: Host, el nombre de tu instancia, Port, el número por el que escucha, y Database, la base a la que quieres llegar. Necesitas una instancia de CrateDB disponible antes de nada, y la documentación de n8n remite a la guía de conexión de CrateDB para los valores por defecto.
- 02
Completa la cuenta y el cifrado
User y Password son la cuenta con la que n8n entra, así que elige una que ya pueda leer y escribir en las tablas implicadas. SSL define cómo se asegura la conexión y admite tres valores: Allow, Disable y Require. Escoge el que corresponde a la configuración de tu clúster, no el que aparezca marcado de entrada.
- 03
Elige la credencial en el nodo
Coloca un nodo CrateDB en el lienzo y selecciona la credencial en su desplegable. Una credencial se crea una vez y se reutiliza en todos los flujos, de modo que el siguiente nodo CrateDB ya te la ofrece sin volver a escribir nada. Después eliges la operación: Execute Query, Insert o Update. Lanzar una consulta corta con Execute Query es la forma más rápida de comprobar que la conexión responde.
¿Qué sabe hacer el nodo CrateDB ?
El nodo CrateDB 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
El SQL que escribas sale tal cual hacia la base conectada y las filas vuelven como items.
Parámetros clave
- Query: la consulta a ejecutar, campo obligatorio. Admite expresiones de n8n y los marcadores
$1y$2, como enWHERE quantity > $1. - Query Parameters: dentro de Additional Fields, la lista separada por comas de las propiedades que se usan como parámetros,
quantity,priceen el ejemplo documentado. - Mode: también en Additional Fields. Multiple Queries es el valor por defecto y envía varias consultas de una vez; Independently ejecuta cada una por separado, junto a Continue on Fail.
Insert rows in database
insertLo que ves en n8n
Notas y casos de uso
Cada item entrante se convierte en una fila de la tabla que indiques.
Parámetros clave
- Schema: obligatorio, el nombre del esquema al que pertenece la tabla.
- Table: obligatorio, la tabla que recibe los datos.
- Columns: la lista separada por comas de las propiedades que sirven de columnas para las nuevas filas, por ejemplo
id,name,description. Añade:typetras un nombre para fijar su tipo de dato, como enid:int,name:text. - Return Fields: los campos que la operación devuelve al flujo una vez escritas las filas.
Update rows in database
updateLo que ves en n8n
Notas y casos de uso
Las filas que ya están en la base se reescriben con los valores que traen los items, sin tocar las demás.
Parámetros clave
- Update Key: obligatorio, la lista separada por comas de las propiedades que deciden qué filas de la base deben actualizarse. Lo normal es que sea
id. - Schema y Table: obligatorios también aquí, apuntan la actualización a una tabla concreta y no a toda la base.
- Columns: las propiedades que se escriben en las filas seleccionadas, por ejemplo
name,description. - Return Fields: lo que vuelve después, útil cuando el nodo siguiente tiene que confirmar el cambio.
¿Necesitas ayuda para automatizar CrateDB con n8n?
El equipo te responde directamente.
Cada mensaje lo lee una persona.
