Bir tetikleyici bir çalışmayı başlatır: girdisi yoktur ve olayı gerçekleştiğinde bir mesaj gönderir. Bir akışta birden fazla tetikleyici olabilir. Bu sayfa, blokların tanımladığı şekliyle her tetikleyiciyi çıktıları ve ayarlarıyla birlikte listeler. Düzenleyicinin Help sekmesi, seçili blok için aynı referansı gösterir.
Mesajlar en az bir kez teslim edilir: bir çökmeden sonra bir mesaj yeniden teslim edilebilir; bu durumda msg.metadata.redelivered = true olarak işaretlenir ve aynı mesaj kimlikleri taşır, böylece dışarı çağrı yapan bloklar aynı idempotency anahtarlarını gönderir. Zamana dayalı ve webhook tetikleyicilerinin skip_redelivered ayarı vardır (varsayılan olarak kapalı): açıkken, yeniden teslim edilen bir mesaj akışı yeniden başlatmaz.
Akış girişi
Başka bir akışın Run flow ile devrettiği mesajların girişi ve bir kök akışta, kökün kapsamındaki cihaz mesajlarının girişidir. Her akışın tam olarak biri vardır; silinemez.
| Çıktı | out: mesaj devredildiği haliyle, aynı çalışmada. Bir IoT kökünde her cihaz mesajı; telemetri her kayıt için bir mesaj olarak. |
| Ayarlar | Yok. Akışın kendisi adrestir. |
| Notlar | Akışın mesaj alabilmesi için açık ve çalışır durumda olması gerekir. Kök akış hiçbir zaman başka bir akış tarafından çalıştırılmaz. Veri yalnızca mesaj üzerinden gelir; alanları Run flow öncesinde ayarlayın. |
Cihaz mesajı (IoT ana bilgisayarı)
Cihazların mesajlarıyla başlar. Cihaz mesajları (telemetry, attributes, connect, disconnect, activity, inactivity, rpc_request, rpc_response) yalnızca bir kök akışa gider; Flow input bağlı olan bir kökte, Flow input onların girişidir. alarm ve attributes_updated mesajları, kök olsun olmasın, adıyla bunları belirten every akışa, yani bir Device message tetikleyicisi olan her akışa gider. Hiçbir tür işaretlenmemiş bir tetikleyici yalnızca cihaz mesajı türlerini dinler: bunları dinlemek için alarm veya attributes_updated türünü adıyla işaretleyin.
| Ayar | Anlamı | Varsayılan | Değerler |
|---|---|---|---|
| types | Akışı başlatan mesaj türleri | every type | telemetry, attributes, connect, disconnect, activity, inactivity, rpc_request, rpc_response, attributes_updated, alarm |
| profiles | Yalnızca bu profillerdeki cihazlar | every profile | cihaz profilleriniz |
| skip_redelivered | Yeniden teslim edilen bir mesaj onu başlatmaz | off | on, off |
Çıktılar: out (telemetri her kayıt için bir mesaj, msg.metadata.recordTs ile), error (bad_payload: hiç kayıt vermeyen telemetri; msg.error.drops her değerin neden atlandığını belirtir).
Salt okunur metadata: msgType, deviceId, profileId, deviceName, profileName, transport (mqtt veya http), ts (alım zamanı), recordTs, topic (yalnızca özel konu verisi), gatewayDeviceId ve diğerleri. Metadata hiçbir zaman saklanmaz.
Inject
Bir akışı elle başlatır (blok üzerindeki düğme), akış başladıktan kısa süre sonra bir kez veya tekrarlı olarak.
| Ayar | Anlamı | Varsayılan | Değerler |
|---|---|---|---|
| payload | msg.payload içine ne gideceği | şu anki zaman (epoch saniyesi) | bir sayı, metin, evet/hayır, JSON, şu anki zaman, hiçbir şey, bir ortam değişkeni veya bir ifade |
| topic | msg.topic | boş | en fazla 256 karakter |
| repeat_ms | Bu süre her seferinde yeniden tetiklenir; 0 = tekrar yok | 0 | en fazla 7 gün; bulutta en az 60 s (planınızın asgari süresi) |
| once_after_ms | Akış başladıktan bu süre sonra bir kez tetiklenir | boş | 0 ila 24 sa |
| originator | Mesajın kimden geldiği | kuruluş | kuruluş veya bu akış (kendi şeridi) |
| msg_type | Mesaj türü | inject | ana bilgisayarın mesaj türlerinden biri |
| metadata | Ek msg.metadata girdileri | yok | en fazla 16 satır |
| times | Bu kadar tekrardan sonra dur | 0 (son yok) | bir tekrar gerektirir |
| catch_up | Bir kesintiden sonra | once | once (kaçırılan en son tetikleme için tek çalışma), skip |
Çıktı: out. Yük, her tetiklendiğinde yeniden hesaplanır.
Zamanlama
Bir akışı duvar saatine göre başlatır.
| Ayar | Anlamı | Varsayılan | Değerler |
|---|---|---|---|
| mode | Zamanın nasıl verildiği | daily | daily, cron, sun |
| time | Günün saati (daily) | 08:00 | HH:MM, 24 saat |
| weekdays | Tetiklendiği günler (daily) | hiçbiri işaretli değilse = her gün | Pzt ila Paz |
| cron | Cron ifadesi | 0 8 * * 1-5 | 5 alan: dakika, saat, ayın günü, ay, haftanın günü |
| sun | Gün doğumu veya batımı | set | rise, set |
| offset_min | Güneş olayından sonra (+) veya önce (−) dakika | 0 | −720 ila 720 |
| lat, lon | Güneş saatleri için konum | boş | −90 ila 90, −180 ila 180; mode sun için required |
| tz | Saat dilimi | kuruluşun varsayılan dilimi | Europe/Istanbul gibi bir IANA adı |
| originator | Mesajın kimden geldiği | kuruluş | kuruluş veya bu akış |
| msg_type | Mesaj türü | schedule | ana bilgisayarın türlerinden biri |
| payload | Standart yükün yerine geçer | { event: "due", mode, at, time } | herhangi bir değer veya ifade |
| catch_up | Bir kesintiden sonra | once | once, skip |
Çıktı out: msg.payload { "event": "due", "mode": "daily", "at": …, "time": … }, msg.topic schedule/<mode>.
- Cron alanları sayıları,
*, aralıkları (1-5), listeleri (1,15) ve adımları (*/10) kabul eder; haftanın günü 0 ve 7 Pazar’dır;MONgibi adlar anlaşılmaz. Ayın günü ve haftanın günü ikisi de kısıtlandığında, ikisinden biri yeterlidir. - Yaz saati uygulamasındaki bir değişiklikle atlanan bir zaman tetiklenmez. Gün doğumu veya batımı olmayan bir gün (kutup bölgeleri) atlanır.
- Bloğun ayarlarındaki Show the next runs, kendi dilimindeki bir sonraki tetikleme zamanlarını listeler.
- Zamanlamanın mesajının bir cihazı yoktur: cihaz mesajı gerektiren bloklar (Save telemetry, Raise alarm, Send command) bunu
not_a_deviceile reddeder.
Adlandırılmış zamanlayıcı
Adlandırılmış bir zamanlayıcı dolduğunda bir akışı başlatır. Timer eylem bloğu, kuruluştaki herhangi bir akıştan onu başlatır, yeniden başlatır veya iptal eder.
| Ayar | Anlamı | Değerler |
|---|---|---|
| name | Dinlenecek zamanlayıcı | required |
Çıktı out: msg.payload { "event": "fired", "name", "ms", "time" }, msg.topic timer/<name>, msg.text “Timer name ran out”. Zamanlayıcılar akışlardaki düzenlemelerden sonra da varlığını sürdürür ve platform tarafından tutulur. Yaşam süresinden uzun bir kesinti sırasında vadesi gelen bir zamanlayıcı, yeniden oynatabileceğiniz başarısız bir mesaja dönüşür.
Webhook
Bloğun adresine bir HTTP POST akışı başlatır. Adres, akış dağıtılıp açıldıktan sonra düzenleyicinin Webhooks penceresinde gösterilir.
| Ayar | Anlamı | Varsayılan | Değerler |
|---|---|---|---|
| auth | Çağıranların kendini nasıl kanıtladığı | token | token (Authorization: Bearer <secret>), hmac (X-Automation-Signature: timestamp.rawBody üzerinde hex HMAC-SHA256 ve 300 s içinde X-Automation-Timestamp), session (kuruluşunuzda oturum açmış bir üye) |
| permission | Yalnızca oturum: çağıranın da sahip olması gereken bir yetki | boş | bir yetki kimliği |
| originator | Mesajın kimin hakkında olduğu | kuruluş | kuruluş veya kuruluşunuzdan bir varlık |
| max_body | En büyük gövde | 16 KiB | en fazla 256 KiB |
| parse | Gövdenin nasıl okunduğu | json | json, text |
| reply | Çağıranın yanıtı ne zaman alacağı | accepted | accepted (hemen bir kimlikle 202), response (bir HTTP response bloğu yanıtlar) |
| timeout_ms | Eşzamanlı bir çağıranın ne kadar bekleyeceği | 10,000 | 1.000 ila 10.000 |
Çıktı out: msg.payload gövdedir; msg.metadata.http method, query ve content-type, user-agent ve x-request-id başlıklarını içerir (asla authorization veya çerezler değil). Bir oturum kancası için msg.metadata.user.id çağırandır.
Yanıtlar: 202 kabul edildi, 401 yanlış token, imza veya oturum, 403 reddedilen oturum, 404 bilinmeyen kanca, 413 gövde çok büyük, 429 hız sınırı veya kota, 503 meşgul. Eşzamanlı bir kanca, akış yanıt göndermezse 204, yakalanmamış hatada 500, süre sonunda 504 yanıtlar. Gizli anahtarlar ve döndürme için Connections and secrets sayfasına bakın.
Olay
Kaynağa ve türe göre seçilen bir olayda başlar; örneğin başka bir akışın Emit event ile gönderdiği olay gibi.
| Ayar | Anlamı | Varsayılan | Değerler |
|---|---|---|---|
| source | Olay kaynağı | any | bir kaynak, ör. flow; * = herhangi |
| kind | Olay türü | any | tam değer, * veya * ile biten bir önek (tank.*) |
| filter | Doğru olması gereken bir ifade | yok | msg üzerinde, en fazla 512 karakter |
Çıktı out: msg.payload olayın verisidir, msg.topic <source>/<kind>. Filtre derlenmezse invalid_value hatası. flow ve platform kaynakları dışında bir tür veya önek belirtmelisiniz.
Catch
Kendi error çıktısı bağlı olmayan aynı akıştaki blokların hatalarını alır.
| Ayar | Anlamı | Varsayılan |
|---|---|---|
| scope | Hataları yakalanan bloklar | akıştaki her blok |
| uncaught_only | Yalnızca başka hiçbir Catch’in almadığı hatalar | off |
Çıktı out: hatalı mesajın bir kopyası, msg.error { message, code, source: { id, type, flow, name } } ile.
Durum
Aynı akıştaki bir blok, altındaki durum satırını her değiştirdiğinde başlar.
| Ayar | Anlamı | Varsayılan |
|---|---|---|
| scope | İzlenen bloklar | akıştaki her blok |
Çıktı out: msg.payload durum metni, msg.status { fill, shape, text, ts, source }. Her bloğu izleyip kendi durumunu ayarlayan bir bloğa (Debug gibi) bağlamayın: sonsuza dek kendini yeniden başlatır.
Complete
Aynı akıştaki seçili bloklar bir mesajı hatasız bitirdiğinde başlar.
| Ayar | Anlamı | Değerler |
|---|---|---|
| nodes | İzlenen bloklar | en fazla 64; hiçbiri = hiç tetiklenmez |
Çıktı out: bitmiş mesajın bir kopyası, msg.complete { id, type, name } ile.
Link in
Link out ve Link call blokların gönderdiği, bu veya aynı ana bilgisayardaki başka bir akıştan adlandırılmış bir giriş.
| Ayar | Anlamı | Değerler |
|---|---|---|
| name | Link blokların kullandığı ad | 1 ila 32 karakter: harfler, rakamlar, _, ., -; benzersiz |
Çıktı out: gelen her mesaj, değiştirilmeden ve aynı çalışmada.
Yorum
Comment bloğu tuvaldeki bir nottur (en fazla 2.048 karakter). Akış çalıştığında hiçbir şey yapmaz.
Link call için Routing and timing blocks, Link out, Emit event, Timer ve Run flow için Action blocks sayfalarına bakın.