Rule Engine & Stream Processing

- Rule engine: SQL-like streaming query (like Flink CEP or custom DSL) - WHEN temperature > 80 FOR 3min THEN alert + send command - Action types: alert (email/SMS/webhook), invoke cloud function, send device command, write to another topic - Windowing: tumbling, sliding, session windows - Complex event processing across multiple devices or metrics