SpecsModelExplore
Overview
Actors
External Systems
IoT Platform
Edge
Ingestion
MQTT Broker
Command Router
Stream Processing
Device Management
User-Facing Apps
Platform
SpecsModelExplore
Ingestion
OverviewGuideLinks and Communications
IDproduct.ingestion
DescriptionCloud-side ingestion of device telemetry and commands.
Keyingestion
Typesystem
TeamIngestion
Owneringestion@iotgateway.example
Statusactive
TechnologiesGo, EMQX/Mosquitto (MQTT), MQTT, TLS
Attributesprotocol: MQTT 5.0, throughput: 1M msgs/s
Tags
Table of contents
Guide
Ingestion
System at a glance
Containers
Responsibilities
Key flows

Guide

Ingestion

Ingestion is the front door of the platform. Every connected device opens a secure session here, streams its telemetry up, and receives cloud-to-device commands back down. If a device can talk to the cloud at all, it is talking to Ingestion first.

Responsibility in one sentence

Terminate millions of secure device connections, fan telemetry into the processing pipeline, and reliably deliver commands back to each device.

System at a glance

Could not build diagram for model "example-iot".

Containers

MQTT Broker

Multi-tenant MQTT broker terminating mutual-TLS device connections.

Command Router

Delivers cloud-to-device commands and tracks acknowledgements.

Responsibilities

  • Mutual-TLS termination for the device fleet.
  • MQTT session, subscription and QoS state.
  • Topic routing for inbound telemetry and outbound commands.
  • Command delivery, retries and acknowledgement tracking.

Key flows

The telemetry alert pipeline begins with messages that arrive here:

Commands dispatched from the cloud are delivered to devices through this system:

New devices establish their first secure session as part of provisioning:

And firmware rollouts ride the same command and telemetry paths:

Links and Communications

1 incoming link · 2 outgoing links

Incoming Links(1)

Source objectLabelLink typeRelationRaw idRequiredDescription
Edge

example-iot.product.edge

system
publishes to—linksproduct.ingestion——

Outgoing Links(2)

Target objectLabelLink typeRelationRaw idRequiredDescription
Stream Processing

example-iot.product.processing

system
feeds—linksproduct.processing——
Device Management

example-iot.product.device_management

system
forwards device events to—linksproduct.device_management——