Redis Trigger

Descripción

El modulo RedisTrigger es un trigger que inicia un workflow cuando se recibe un mensaje en un canal Redis Pub/Sub configurado. Soporta dos tipos de suscripción: subscribe para canales exactos y psubscribe para patrones con wildcards (*). El modulo intenta parsear automáticamente el mensaje como JSON; si no es JSON valido, lo pasa como string. Proporciona el canal, el mensaje parseado, el mensaje raw y metadata del trigger al siguiente nodo.

Configuración

Parámetros

Parámetro	Tipo	Requerido	Descripción
credentials_id	credentials	Si	Credenciales de conexión Redis (host, port, password).
channel	text	Si	Canal Redis Pub/Sub. Para psubscribe usar patrones con . Ej: eventos:, notificaciones:pedidos
subscription_type	select	No	Tipo de suscripción: Subscribe (canal exacto) o PSubscribe (patron con wildcard *). Por defecto: subscribe.
trigger_id	hidden	No	ID del trigger registrado. Se genera automáticamente.

Credenciales

Se requiere una credencial con los siguientes campos:

• host: Host del servidor Redis (ej: localhost o redis.ejemplo.com).
• port: Puerto de conexión (por defecto: 6379).
• password: Contrasena de autenticación del servidor Redis.

Salida

{
  "nextModule": "siguiente_modulo",
  "data": {
    "channel": "eventos:pedidos",
    "message": { "pedido_id": 456, "estado": "completado" },
    "raw": "{\"pedido_id\":456,\"estado\":\"completado\"}",
    "_trigger": {
      "type": "redis",
      "channel": "eventos:pedidos",
      "pattern": null,
      "subscription_type": "subscribe",
      "timestamp": "2026-03-23T10:00:00.000Z"
    }
  }
}

Ejemplo de Uso

Caso básico

{
  "label": "Redis Trigger",
  "credentials_id": "credencial_redis",
  "channel": "eventos:*",
  "subscription_type": "psubscribe"
}

Notas

• subscribe escucha en un canal exacto. psubscribe permite patrones con wildcard * para escuchar múltiples canales.
• Cuando se usa psubscribe, el campo _trigger.pattern contiene el patron original de suscripción.
• El mensaje se intenta parsear como JSON automáticamente. Si falla, se mantiene como string.
• El campo raw siempre contiene el mensaje original sin parsear.

Nodos Relacionados

• MqttTrigger (trigger similar para mensajes MQTT)
• Webhook (trigger por petición HTTP)
• decision (para evaluar el contenido del mensaje)