Un déclencheur démarre une exécution : il n’a pas d’entrée et envoie un message lorsque son événement se produit. Un flux peut avoir plusieurs déclencheurs. Cette page répertorie tous les déclencheurs avec leurs sorties et leurs paramètres, tels que définis par les blocs. L’onglet Aide de l’éditeur affiche la même référence pour le bloc sélectionné.
Les messages sont livrés au moins une fois : après un plantage, un message peut être livré à nouveau, marqué msg.metadata.redelivered = true, avec les mêmes identifiants de message, de sorte que les blocs qui appellent un service envoient les mêmes clés d’idempotence. Les déclencheurs temporels et webhook disposent d’un paramètre skip_redelivered (désactivé par défaut) : activé, un message redélivré ne redémarre pas le flux.
Entrée du flux
L’entrée des messages qu’un autre flux transmet avec Run flow et, dans un flux racine, des messages d’appareils du périmètre de la racine. Chaque flux en possède exactement un ; il ne peut pas être supprimé.
| Sortie | out : le message tel qu’il a été transmis, dans la même exécution. Dans une racine IoT, chaque message d’appareil ; la télémétrie donne un message par enregistrement. |
| Paramètres | Aucun. Le flux lui-même est l’adresse. |
| Remarques | Le flux doit être activé et en cours d’exécution pour recevoir des messages. Une racine n’est jamais exécutée par un autre flux. Les données ne passent que par le message ; définissez les champs avant Run flow. |
Message d’appareil (hôte IoT)
Démarre sur les messages des appareils. Les messages d’appareils (telemetry, attributes, connect, disconnect, activity, inactivity, rpc_request, rpc_response) vont à un seul flux racine uniquement ; dans une racine dont l’Entrée du flux est reliée, l’Entrée du flux est leur point d’entrée. Les messages alarm et attributes_updated vont à tous les flux comportant un déclencheur Message d’appareil qui les nomme, racine ou non. Un déclencheur sans type coché n’écoute que les types de messages d’appareils : cochez alarm ou attributes_updated par nom pour les recevoir.
| Paramètre | Signification | Défaut | Valeurs |
|---|---|---|---|
| types | Les types de messages qui le démarrent | tous les types | telemetry, attributes, connect, disconnect, activity, inactivity, rpc_request, rpc_response, attributes_updated, alarm |
| profiles | Uniquement les appareils de ces profils | tous les profils | vos profils d’appareils |
| skip_redelivered | Un message redélivré ne le démarre pas | off | on, off |
Sorties : out (télémétrie, un message par enregistrement, avec msg.metadata.recordTs), error (bad_payload : télémétrie sans enregistrement ; msg.error.drops indique pourquoi chaque valeur a été omise).
Métadonnées en lecture seule : msgType, deviceId, profileId, deviceName, profileName, transport (mqtt ou http), ts (heure de réception), recordTs, topic (données de sujet personnalisé uniquement), gatewayDeviceId, et d’autres. Les métadonnées ne sont jamais stockées.
Inject
Démarre un flux manuellement (le bouton du bloc), une fois peu après le démarrage du flux, ou de façon répétée.
| Paramètre | Signification | Défaut | Valeurs |
|---|---|---|---|
| payload | Ce qui est placé dans msg.payload | l’heure actuelle (secondes epoch) | un nombre, un texte, oui/non, JSON, l’heure actuelle, rien, une variable d’environnement ou une expression |
| topic | msg.topic | vide | jusqu’à 256 caractères |
| repeat_ms | Redémarre après cette durée ; 0 = pas de répétition | 0 | jusqu’à 7 jours ; au moins 60 s sur le cloud (minimum de votre offre) |
| once_after_ms | Démarre une fois après cette durée suivant le lancement du flux | vide | 0 à 24 h |
| originator | L’expéditeur du message | l’organisation | l’organisation, ou ce flux (sa propre file) |
| msg_type | Le type de message | inject | l’un des types de messages de l’hôte |
| metadata | Entrées supplémentaires de msg.metadata | aucune | jusqu’à 16 lignes |
| times | Arrêter après ce nombre de répétitions | 0 (sans fin) | nécessite une répétition |
| catch_up | Après une interruption | once | once (une exécution pour le déclenchement manqué le plus récent), skip |
Sortie : out. La charge utile est calculée à chaque déclenchement.
Planification
Démarre un flux selon l’horloge murale.
| Paramètre | Signification | Défaut | Valeurs |
|---|---|---|---|
| mode | Mode de saisie de l’heure | daily | daily, cron, sun |
| time | Heure du jour (daily) | 08:00 | HH:MM, 24 heures |
| weekdays | Jours de déclenchement (daily) | aucun coché = tous les jours | lun. à dim. |
| cron | Expression cron | 0 8 * * 1-5 | 5 champs : minute, heure, jour du mois, mois, jour de la semaine |
| sun | Lever ou coucher du soleil | set | rise, set |
| offset_min | Minutes après (+) ou avant (−) l’événement solaire | 0 | −720 à 720 |
| lat, lon | Position pour les heures solaires | vide | −90 à 90, −180 à 180 ; obligatoire pour le mode sun |
| tz | Fuseau horaire | le fuseau par défaut de l’organisation | un nom IANA tel que Europe/Istanbul |
| originator | L’expéditeur du message | l’organisation | l’organisation, ou ce flux |
| msg_type | Le type de message | schedule | l’un des types de l’hôte |
| payload | Remplace la charge utile standard | { event: "due", mode, at, time } | toute valeur ou expression |
| catch_up | Après une interruption | once | once, skip |
Sortie out : msg.payload { "event": "due", "mode": "daily", "at": …, "time": … }, msg.topic schedule/<mode>.
- Les champs cron acceptent des nombres,
*, des plages (1-5), des listes (1,15) et des pas (*/10) ; le jour de la semaine 0 et 7 désignent le dimanche ; les noms tels queMONne sont pas reconnus. Lorsque le jour du mois et le jour de la semaine sont tous deux restreints, l’un ou l’autre suffit. - Une heure sautée par un changement d’heure d’été ne déclenche pas le flux. Un jour sans lever ni coucher de soleil (régions polaires) est ignoré.
- Show the next runs dans les paramètres du bloc affiche les prochaines heures de déclenchement dans son fuseau.
- Le message d’une planification n’a pas d’appareil : les blocs qui en exigent un (Save telemetry, Raise alarm, Send command) le refusent avec
not_a_device.
Minuterie nommée
Démarre un flux lorsqu’une minuterie nommée arrive à échéance. Le bloc d’action Timer la démarre, la redémarre ou l’annule, depuis n’importe quel flux de l’organisation.
| Paramètre | Signification | Valeurs |
|---|---|---|
| name | La minuterie à écouter | obligatoire |
Sortie out : msg.payload { "event": "fired", "name", "ms", "time" }, msg.topic timer/<name>, msg.text « Timer name ran out ». Les minuteries survivent aux modifications des flux et sont conservées par la plateforme. Une minuterie échue pendant une panne plus longue que la durée de vie (time-to-live) devient un message en échec que vous pouvez rejouer.
Webhook
Un POST HTTP vers l’adresse du bloc démarre le flux. L’adresse s’affiche dans la boîte de dialogue Webhooks de l’éditeur une fois le flux déployé et activé.
| Paramètre | Signification | Défaut | Valeurs |
|---|---|---|---|
| auth | Comment les appelants prouvent leur identité | token | token (Authorization: Bearer <secret>), hmac (X-Automation-Signature : HMAC-SHA256 hexadécimal de timestamp.rawBody, et X-Automation-Timestamp dans les 300 s), session (un membre connecté de votre organisation) |
| permission | Session uniquement : une permission que l’appelant doit aussi détenir | vide | un identifiant de permission |
| originator | À qui le message se rapporte | l’organisation | l’organisation, ou une entité de votre organisation |
| max_body | Corps le plus grand | 16 KiB | au plus 256 KiB |
| parse | Comment le corps est lu | json | json, text |
| reply | Quand l’appelant reçoit sa réponse | accepted | accepted (202 avec un identifiant immédiatement), response (un bloc HTTP response répond) |
| timeout_ms | Durée d’attente d’un appelant synchrone | 10,000 | 1 000 à 10 000 |
Sortie out : msg.payload est le corps ; msg.metadata.http contient method, query et les en-têtes content-type, user-agent et x-request-id (jamais authorization ni les cookies). Pour un hook de session, msg.metadata.user.id est l’appelant.
Réponses : 202 acceptée, 401 jeton, signature ou session incorrects, 403 session refusée, 404 point d’entrée inconnu, 413 corps trop volumineux, 429 limite de débit ou quota atteint, 503 occupé. Un point d’entrée synchrone répond 204 lorsque le flux n’envoie aucune réponse, 500 en cas d’erreur non interceptée, 504 à l’échéance. Voir Connexions et secrets pour les secrets et leur rotation.
Événement
Démarre sur un événement choisi par source et type, par exemple celui qu’un autre flux a émis avec Emit event.
| Paramètre | Signification | Défaut | Valeurs |
|---|---|---|---|
| source | La source de l’événement | any | une source, par ex. flow ; * = toute |
| kind | Le type d’événement | any | exact, *, ou un préfixe suivi de * (tank.*) |
| filter | Une expression qui doit être vraie | none | sur msg, jusqu’à 512 caractères |
Sortie out : msg.payload contient les données de l’événement, msg.topic <source>/<kind>. Erreur invalid_value lorsque le filtre ne compile pas. Sauf pour les sources flow et platform, vous devez indiquer un type ou un préfixe.
Catch
Reçoit les erreurs des blocs du même flux dont la sortie error n’est pas raccordée.
| Paramètre | Signification | Défaut |
|---|---|---|
| scope | Les blocs dont les erreurs sont interceptées | chaque bloc du flux |
| uncaught_only | Seulement les erreurs qu’aucun autre Catch ne prend en charge | off |
Sortie out : une copie du message en échec avec msg.error { message, code, source: { id, type, flow, name } }.
Status
Démarre chaque fois qu’un bloc du même flux modifie la ligne d’état qui lui est associée.
| Paramètre | Signification | Défaut |
|---|---|---|
| scope | Les blocs surveillés | chaque bloc du flux |
Sortie out : msg.payload contient le texte d’état, msg.status { fill, shape, text, ts, source }. Ne surveillez pas tous les blocs en raccordant la sortie à un bloc qui définit son propre statut (comme Debug) : il redémarrerait lui-même indéfiniment.
Complete
Démarre lorsque les blocs sélectionnés du même flux terminent un message sans erreur.
| Paramètre | Signification | Valeurs |
|---|---|---|
| nodes | Les blocs surveillés | jusqu’à 64 ; none = ne se déclenche jamais |
Sortie out : une copie du message terminé avec msg.complete { id, type, name }.
Link in
Une entrée nommée vers laquelle les blocs Link out et Link call envoient des messages, depuis ce flux ou un autre flux du même hôte.
| Paramètre | Signification | Valeurs |
|---|---|---|
| name | Le nom utilisé par les blocs de liaison | de 1 à 32 caractères : lettres, chiffres, _, ., - ; unique |
Sortie out : chaque message reçu, inchangé et dans la même exécution.
Comment
Un bloc Comment est une note sur le canevas (jusqu’à 2 048 caractères). Il n’a aucun effet lorsque le flux s’exécute.
Voir aussi Blocs de routage et de temporisation pour Link call, et Blocs d’action pour Link out, Emit event, Timer et Run flow.