SOP Fan-In: MQTT
Los mensajes MQTT pueden iniciar ejecuciones de SOP. El oyente MQTT se suscribe al broker, construye un evento SOP por cada mensaje y lo envía al motor. Esta ruta está controlada por la característica de compilación channel-mqtt.
El lado de transporte (URL del broker, credenciales, TLS, QoS) se configura en el canal MQTT. Esta página cubre el trigger.
Activador
Llegada de mensajes MQTT. En vivo: entregado por el listener de MQTT.
| campo | tipo | predeterminado | significado |
|---|---|---|---|
condition | string? | null | Expresión opcional evaluada contra la carga útil del mensaje; la ejecución |
topic* | cadena | — | Filtro de temas. + coincide con un nivel, # coincide con los niveles restantes. |
Cargar y verificar el SOP:
Definir
Autorice el SOP como se describe en Syntax, con un desencadenador mqtt. Los campos del desencadenador anteriores son las claves compatibles; la página recorre el archivo completo.
Validar
zeroclaw sop validate
Inspeccionar
zeroclaw sop list
zeroclaw sop show <name>
Coincidencia
Los patrones de tópico admiten los comodines + (un solo nivel) y # (varios niveles). La carga útil de MQTT se reenvía a la carga útil del evento SOP, disponible para una condition opcional del trigger; el contexto del paso recibe la forma acotada, saneada y enmarcada. Una condition de ruta JSON como $.value > 85 requiere que el publicador envíe un cuerpo JSON.
Dispararlo
Con una SOP cargada y el canal MQTT suscrito, publica un mensaje en un tema cuyo patrón coincida con el activador (por ejemplo con mosquitto_pub, o con cualquier cliente del broker). El oyente construye un evento a partir del tema y la carga útil y lo despacha. Se inicia una ejecución para cada SOP cargada cuyo patrón topic coincida y cuya condition (si la hay) se cumpla con la carga útil.
Si nada se inicia, confirme que el tema coincide con el patrón de activación, que la suscripción del broker está activa y que condition coincide con la carga útil. Consulte la tabla de solución de problemas de la descripción general de fan-in.
Aprueba y observa
Las ejecuciones que alcanzan un punto de control se pausan como WaitingApproval. Límpialas o inspecciónalas con la CLI (zeroclaw sop list, zeroclaw sop approve) o fuera de banda mediante los endpoints de aprobación de la gateway API (GET /admin/sop/pending, POST /admin/sop/approve, POST /admin/sop/deny).
Ver también
- MQTT channel: broker, TLS, QoS
- Descripción general de fan-in
- Sintaxis: el formato de archivo SOP