Überblick über Events-Provider

Einführung

Events-Provider ermöglichen es Ihrem Digital Worker, auf externe Trigger außerhalb von Messaging zu reagieren. Sie verarbeiten:

Webhooks von externen Diensten
Geplante Aufgaben (Timer/Cron)
E-Mail-Benachrichtigungen
SMS-Benachrichtigungen

Verfügbare Provider

Webhook HTTP-Webhooks von externen Diensten empfangen

Timer Aufgaben mit Cron-Ausdrücken planen

E-Mail (SendGrid) Transaktionale E-Mails über SendGrid senden

SMS (Twilio) SMS-Nachrichten über Twilio senden

Architektur

External Service / Timer
    │
    ▼ HTTP / Schedule
┌─────────────────────────────────────────┐
│           Events Ingress                │
│     (Process incoming event)            │
└─────────────────────────────────────────┘
    │
    ▼ Normalized Event
┌─────────────────────────────────────────┐
│              NATS Bus                   │
│    greentic.events.{env}.{tenant}.{type}│
└─────────────────────────────────────────┘
    │
    ▼
┌─────────────────────────────────────────┐
│           Flow Executor                 │
│      (Process with event flows)         │
└─────────────────────────────────────────┘

Ereignisnormalisierung

Alle Ereignisse werden auf ein gemeinsames Format normalisiert:

pub struct Event {
    pub id: String,
    pub event_type: String,
    pub source: String,
    pub timestamp: u64,
    pub payload: Value,
    pub metadata: Option<Value>,
}

Konfiguration

Im Bundle

providers:
  events-webhook:
    pack: "providers/events/events-webhook.gtpack"

  events-timer:
    pack: "providers/events/events-timer.gtpack"

Event-Flows

name: handle_event
version: "1.0"

nodes:
  - id: process
    type: script
    config:
      script: |
        // Process the event
        let payload = event.payload;
        process_payload(payload)
    next: respond

triggers:
  - type: event
    event_type: "order.created"
    target: process

NATS-Subjects

Ereignisse fließen über NATS:

Subject	Zweck
`greentic.events.{env}.{tenant}.{type}`	Ereignisbenachrichtigungen
`greentic.events.{env}.{tenant}.{type}.result`	Ergebnisse der Ereignisverarbeitung

Häufige Muster

Ereignisgesteuerte Benachrichtigungen

nodes:
  - id: on_order
    type: branch
    config:
      conditions:
        - expression: "event.event_type == 'order.created'"
          next: send_confirmation
        - expression: "event.event_type == 'order.shipped'"
          next: send_tracking

Geplante Aufgaben

nodes:
  - id: daily_report
    type: http
    config:
      method: GET
      url: "https://api.example.com/reports/daily"
    next: send_email

triggers:
  - type: timer
    cron: "0 9 * * *"  # 9 AM daily
    target: daily_report