INTEGRACIÓN TIMESCALEDB n8n: AUTOMATIZAR TIMESCALEDB CON N8N

La acción Insert te permite añadir nuevos registros en una tabla de TimescaleDB directamente desde n8n. Es particularmente útil para alimentar tu base de datos de series temporales con datos provenientes de sensores, APIs externas o cualquier fuente conectada a tu workflow. Esta acción simplifica la inserción masiva de datos sin necesidad de escribir consultas SQL manualmente.

Parámetros clave:

• Schema: Campo de texto requerido donde especificas el esquema de la base de datos que contiene tu tabla (por defecto "public").
• Table: Campo de texto requerido para indicar el nombre exacto de la tabla en la que insertarás los datos.
• Columns: Campo de texto requerido que acepta una lista de nombres de columnas separados por comas (ej: "id,name,description"), definiendo exactamente qué columnas poblarás con datos.
• Return Fields: Campo de texto opcional que determina qué campos serán devueltos tras la inserción. Por defecto "*" (todos los campos), pero puedes especificar columnas concretas para optimizar la respuesta.
• Additional Fields: Sección opcional para añadir configuraciones avanzadas como manejo de conflictos o cláusulas SQL específicas mediante el botón "Add Field".

Casos de uso típicos: Insertar automáticamente mediciones de sensores IoT (temperatura, presión, vibración) recibidas vía webhook o MQTT en tu hypertable de TimescaleDB. Alimentar una tabla de eventos de usuario desde tu aplicación web cada vez que se completa una acción (clics, compras, registros). Crear registros históricos de precios de productos sincronizados desde un e-commerce o API de mercado financiero.

Cuándo usarlo: Ideal cuando necesitas añadir continuamente nuevos datos a TimescaleDB sin modificar registros existentes. Perfecto para pipelines ETL (Extract-Transform-Load) donde n8n extrae datos de múltiples fuentes y los centraliza en tu base de datos de series temporales.

La acción Update permite modificar registros existentes en tu base de datos TimescaleDB basándote en una clave de actualización (update key). Esta acción es esencial cuando necesitas corregir datos, actualizar estados o enriquecer registros con información proveniente de otras aplicaciones conectadas a n8n, como tu CRM HubSpot o herramientas de gestión.

Parámetros clave:

• Schema: Campo de texto requerido para especificar el esquema de la base de datos (habitualmente "public").
• Table: Campo de texto requerido donde indicas la tabla que contiene los registros a actualizar.
• Update Key: Campo de texto requerido que define la columna utilizada como identificador único (clave primaria) para localizar los registros a modificar. En la captura, "id" actúa como update key.
• Columns: Campo de texto requerido con los nombres de las columnas a actualizar, separados por comas (ej: "name,description" en la captura).
• Return Fields: Campo de texto opcional que especifica qué campos devolver tras la actualización. Por defecto "*" (todos), pero puedes limitar la respuesta a columnas específicas.
• Additional Fields: Sección opcional para añadir propiedades o condiciones avanzadas mediante "Add Field", aunque no se muestran configuradas en esta vista.

Casos de uso típicos: Actualizar el estado de pedidos en TimescaleDB cuando cambian en tu CRM o plataforma de e-commerce. Modificar valores de métricas (precio, stock, disponibilidad) sincronizadas desde APIs externas. Enriquecer registros existentes con datos calculados o transformados por otros nodos de tu workflow n8n.

Cuándo usarlo: Utiliza esta acción cuando necesites sincronizar cambios bidireccionales entre TimescaleDB y otras aplicaciones, o cuando tus workflows requieran corregir/actualizar datos históricos basándose en eventos externos.

La acción Execute Query es la más flexible de las tres, permitiéndote ejecutar cualquier consulta SQL personalizada directamente contra tu base de datos TimescaleDB. Ideal para operaciones complejas que van más allá de inserciones o actualizaciones simples: agregaciones, joins, deletes, creación de tablas, funciones de ventana (window functions) para series temporales, etc.

Parámetros clave:

• Query: Campo de texto requerido (área de texto) donde introduces la consulta SQL completa a ejecutar. Acepta cualquier sintaxis SQL válida compatible con PostgreSQL/TimescaleDB. En la captura, se muestra un valor placeholder "1", pero aquí deberías introducir tu SELECT, INSERT, UPDATE, DELETE, o consultas de análisis temporal como time_bucket().
• Additional Fields: Sección opcional para añadir más propiedades de configuración mediante el botón "Add Field", aunque no se muestran propiedades activas en esta vista.

Casos de uso típicos: Ejecutar consultas de agregación temporal programadas: calcular promedios horarios de temperatura usando time_bucket(), generar reportes diarios de ventas o extraer tendencias mensuales. Realizar operaciones complejas de limpieza de datos: eliminar registros antiguos con DELETE WHERE timestamp < NOW() - INTERVAL '90 days'. Crear vistas materializadas o actualizar continuous aggregates de TimescaleDB para optimizar consultas futuras. Ejecutar queries analíticas ad-hoc que combinan múltiples tablas con JOINs para generar dashboards o reportes personalizados enviados por email vía Gmail o Slack.

Cuándo usarlo: Perfecta para casos de uso avanzados donde necesitas el control total de la consulta SQL. Úsala cuando las acciones Insert/Update no cubren tu necesidad específica, o cuando necesites aprovechar funciones nativas de TimescaleDB como compresión, políticas de retención o análisis de series temporales con funciones hiperbólicas.