Keyboard shortcuts

Press ← or → to navigate between chapters

Press ? to show this help

Press Esc to hide this help

SOP Fan-In: AMQP

Les livraisons AMQP peuvent déclencher des exécutions SOP. Lorsqu’un alias s’exécute en mode de dispatch SOP, le consommateur AMQP transforme chaque livraison en un événement SOP (la clé de routage devient le topic de l’événement, le corps du message devient la charge utile) et le transmet au moteur.

Le côté transport (connexion au broker, file d’attente, exchange, TLS) est configuré sur le canal AMQP. Cette page couvre le déclencheur. Le mode de dispatch qui décide si les livraisons pilotent la boucle d’agent, le moteur SOP, ou les deux est le champ dispatch du canal.

Déclencheur

Livraison AMQP. En direct : livrée par le consommateur AMQP dans un mode de dispatch SOP.

champtypepar défautsens
conditionstring?nullExpression optionnelle évaluée par rapport au corps de la livraison.
routing_key*chaîne—Filtre de clé de routage (sémantique d’échange de type topic) : mots .-délimités,

Charger et vérifier le SOP :

Définir

Rédigez le SOP comme décrit dans Syntaxe, avec un déclencheur amqp. Les champs de déclencheur ci-dessus correspondent aux clés prises en charge ; la page parcourt l’intégralité du fichier.

Valider

zeroclaw sop validate

Inspect

zeroclaw sop list
zeroclaw sop show <name>

Correspondance

Le routing_key utilise la sémantique des exchanges de type topic AMQP : les clés sont des mots .-délimités, * correspond exactement à un mot, et # correspond à zéro ou plusieurs mots. Le corps de la livraison est transmis dans la charge utile de l’événement SOP, disponible pour une condition de déclenchement optionnelle ; le contexte de l’étape reçoit la forme plafonnée, assainie et encadrée. Une condition JSON-path telle que $.value > 85 nécessite que l’éditeur envoie un corps JSON.

Exécutez-le

Définissez le champ dispatch du canal sur un mode SOP (sop ou sop_and_agent_loop), chargez un SOP, puis publiez un message sur l’exchange avec une clé de routage à laquelle le déclencheur correspond. Le consommateur transforme la livraison en un événement (clé de routage en topic, corps en payload) et le dispatche. Une exécution démarre pour chaque SOP chargé dont le motif routing_key correspond et dont la condition (le cas échéant) est satisfaite par le corps.

Si rien ne démarre, vérifiez que dispatch est bien en mode SOP, que la queue est liée afin que la clé de routage atteigne bien le consommateur, et que la condition correspond. Consultez le tableau de dépannage de la vue d’ensemble fan-in.

Approuver et observer

Les exécutions qui atteignent un point de contrôle se mettent en pause en tant que WaitingApproval. Effacez-les ou inspectez-les avec le CLI (zeroclaw sop list, zeroclaw sop approve) ou hors bande via les endpoints d’approbation de la gateway API (GET /admin/sop/pending, POST /admin/sop/approve, POST /admin/sop/deny).

Voir aussi