Automatyzacje i wyzwalacze¶
Cel¶
Automatyzacja uruchamia zdefiniowany workflow na podstawie czasu, zdarzenia, progu, wiadomości lub decyzji człowieka. Trigger nigdy nie jest capability. Może utworzyć żądanie pracy, ale wszystkie nodes podlegają standardowej polityce i approvalom.
Karta modułu¶
| Pole | Kontrakt |
|---|---|
| Odpowiedzialności | odbiór, uwierzytelnienie, normalizacja, deduplikacja, rate limit, routing i harmonogram. |
| Wejścia | cron/calendar, webhook, channel event, sensor event, file event, threshold, manual start. |
| Wyjścia | TriggerEvent, workflow run albo jawne rejected/deduplicated. |
| Zależności | Channel/Event Gateway, Scheduler, Workflow Registry, Accounts, Audit. |
| Uprawnienia | trigger ma prawo zgłosić zdarzenie; nie może zatwierdzić efektu. |
| Autonomia | automatyczny start tylko aktywnej definicji w limicie i zakresie. |
| Walidacja | source authentication, schema, timestamp window, dedupe key, rate, route i data class. |
| Awaria | durable inbox, replay z dedupe, dead-letter i operator review. |
Rodzaje triggerów¶
- czasowe — dokładny termin, okno cykliczne, święta, timezone i catch-up policy;
- zdarzeniowe — zmiana rekordu, nowy plik, zakończony job, alert aplikacji;
- kanałowe — wiadomość, połączenie, formularz, webhook; treść jest niezaufana;
- sensoryczne — kamera, czujnik, UPS, temperatura, obecność, licznik;
- progowe — odchylenie KPI, brak odpowiedzi, zużycie zasobu;
- złożone — korelacja kilku zdarzeń w oknie czasu.
Lifecycle¶
Trigger przechodzi draft → active → paused/disabled/revoked. Aktywacja jest osobnym approvalem. Zmiana harmonogramu, źródła, route, limitu lub workflow tworzy nową wersję albo wymaga review zależnie od polityki. Agent może zaproponować trigger po wykryciu powtarzalnej pracy, ale nie może go włączyć.
Ochrona przed burzą zdarzeń¶
Gateway wylicza stabilny event ID, source ID, correlation key i dedupe window. Limity są per źródło, projekt i typ. Np. 500 podobnych detekcji kamery w minutę może zostać zagregowane do jednego incydentu z licznikiem oraz reprezentatywnymi klatkami. Circuit breaker wstrzymuje routing, ale zachowuje statystyki i próbki do analizy.
Przykładowe polecenia¶
- „Codziennie o 7:00 przygotuj raport nocnych alarmów, ale nie wysyłaj go automatycznie.”
- „Jeśli pracownik nie potwierdzi zmiany do 18:00, utwórz zadanie dla kierownika.”
- „Po zakończeniu renderu uruchom QC i powiadom mnie tylko, gdy są błędy.”
- „Zaproponuj automatyzację powtarzalnych faktur, lecz pozostaw ją w draft.”
Pełny przebieg¶
Trigger „nowa faktura” weryfikuje źródło skrzynki, deduplikuje message ID i zapisuje załącznik w Artifact Store. Workflow rozpoznaje typ dokumentu, ekstrahuje dane, sprawdza sumę i dopasowuje zamówienie. Niezgodność tworzy wyjątek. Zgodny dokument może otrzymać candidate dekretację, ale finalny zapis księgowy ma osobne narzędzie i politykę. Tekst faktury nie może aktywować płatności.
Błędy i scenariusz awaryjny¶
Przy niedostępności brokera zdarzenia trafiają do trwałego inboxu w ograniczonym buforze. Po odzyskaniu są odtwarzane z dedupe; polityka catch-up rozstrzyga, czy stare zdarzenie nadal ma sens. Przekroczenie pojemności nie prowadzi do cichej utraty: powstaje alert i licznik dropped/quarantined. Trigger z niezgodnym schematem zostaje odrzucony, a nie „naprawiony” modelem.