Data Flow

The telemetry flow is intentionally asynchronous.

1. A LoRaWAN device sends an uplink.
2. The external Network Server receives and decrypts the payload.
3. The Network Server publishes an MQTT message.
4. mqtt-ingestion-worker validates the minimal envelope.
5. The worker publishes a raw ingestion event to the internal broker.
6. telemetry-worker consumes the event.
7. The worker identifies the device and tenant scope.
8. The raw payload is stored for short-term retention.
9. The configured decoder version produces normalized measurements.
10. Measurements are stored for long-term retention.

Duplicate, delayed, out-of-order, malformed, and unknown-device messages must be handled without stopping the ingestion pipeline.