MQTT Stream
Streams real-time messages from MQTT topics, enabling data ingestion from IoT sensors and other telemetry feeds.
Custom Streaming
Create or update a recurring MQTT stream connector. Subscribes to MQTT topics and streams messages to Delphi. Use this for IoT sensors, telemetry feeds, and any MQTT broker.
What you can ask Delphi
- “What is the current temperature reading from the 'building_A/sensor_1' MQTT topic?”
- “Show me the last 24 hours of energy consumption data reported on the 'factory_floor/power_meter' MQTT topic.”
- “Are there any current alerts or anomalies reported on the 'environmental_monitors/alarms' MQTT stream?”
- “What is the battery level of device 'asset_tracker_XYZ' as reported on its MQTT telemetry stream?”
Technical details
Authentication ▾
Contact us for setup details.
Ingestion ▾
Mode: Streaming
Tools exposed (1) ▾
schedule_stream_mqtt
Create or update a recurring MQTT stream connector. Subscribes to MQTT topics and streams messages to Delphi. Use this for IoT sensors, telemetry feeds, and any MQTT broker.
Inputs ▾
schedule_stream_mqtt
| Name | Type | Required | Description |
|---|---|---|---|
| dashboardId | string | no | Target dashboard/initiative ID. Omit to use the current dashboard. |
| brokerUrls | string[] | yes | MQTT broker URLs, e.g. ["tcp://broker.example.com:1883", "ssl://secure-broker.example.com:8883"]. |
| topics | string[] | yes | MQTT topics to subscribe to, e.g. ["sensors/#", "telemetry/+/data"]. Supports MQTT wildcards. |
| qos | number | no | Quality of Service level: 0 (at most once), 1 (at least once, default), 2 (exactly once). |
| clientId | string | no | MQTT client ID. If omitted, auto-generated as 'delphi-<connectorId>'. |
| username | string | no | MQTT broker username for authentication. |
| passwordEnvVar | string | no | Name of the environment variable containing the MQTT password. Never pass the password directly. |
| recordPath | string | no | Dot path to extract from each message JSON, e.g. 'payload.readings'. |
| connectorId | string | no | If provided, updates the existing connector instead of creating a new one. |
| description | string | no | Human-readable description of what this MQTT connector monitors. |
| idExpression | string | no | Optional expression for the deduplication key. Provide this when messages have a stable unique field. |
| tlsEnabled | boolean | no | Enable TLS for the MQTT connection. |
| tlsSkipVerify | boolean | no | Skip TLS certificate verification. Only use for development/testing. |
| keepAlive | number | no | Keepalive interval in seconds. Default 30. |
| cleanSession | boolean | no | Start a clean MQTT session. Default true. |