Redis Trigger

Descripcion

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 suscripcion: subscribe para canales exactos y psubscribe para patrones con wildcards (*). El modulo intenta parsear automaticamente 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.

Configuracion

Parametros

Parametro	Tipo	Requerido	Descripcion
credentials_id	credentials	Si	Credenciales de conexion 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 suscripcion: Subscribe (canal exacto) o PSubscribe (patron con wildcard *). Por defecto: subscribe.
trigger_id	hidden	No	ID del trigger registrado. Se genera automaticamente.

Credenciales

Se requiere una credencial con los siguientes campos:

• host: Host del servidor Redis (ej: localhost o redis.ejemplo.com).
• port: Puerto de conexion (por defecto: 6379).
• password: Contrasena de autenticacion 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 basico

{
  "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 multiples canales.
• Cuando se usa psubscribe, el campo _trigger.pattern contiene el patron original de suscripcion.
• El mensaje se intenta parsear como JSON automaticamente. 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 peticion HTTP)
• decision (para evaluar el contenido del mensaje)