Skip to main content

Step 6 — Deploy the MQTT-InfluxDB Ingester

This article refers to Platform v3.0.0. The current Platform version is v3.2.0.
warning

This step assumes the previous five steps are already running on the node (MQTT BrokerInfluxDB).

Overview

The MQTT-InfluxDB Ingester is the bridge between MQTT and InfluxDB. It subscribes to the YOLOv8 telemetry stream on the broker and writes every message into an InfluxDB bucket, ready to be queried from Grafana in the next step.

Ingester in the pipeline

Ingester in the pipeline

Add the Ingester to your Library

Marketplace badge
MQTT-InfluxDB Ingester icon

MQTT-InfluxDB Ingester

Service that extracts data from the MQTT Broker and writes it to the InfluxDB database.

Ingester in the Marketplace

Ingester in the Marketplace

Ingester in the App Library

Ingester in the App Library

Deploy the Ingester

  1. Open the Node Details page and click Add card → Application.
Add card menu

Add card menu

Select Application

Select Application

  1. Select app and version. Pick MQTT-InfluxDB Ingester and its latest version. Click Next.
Select Ingester

Select Ingester

  1. App Secrets. Keep the defaults and click Next.
App Secrets for the Ingester

App Secrets for the Ingester

  1. App Config. Paste the JSON below — deviceDisplayName must match displayNameTelemetry from the YOLOv8 App Config (yolov8_telemetry_01).

    {
    "ingestorMqttInfluxdb": {
    "inputs": [
    {
    "bucketInflux": "bbrbucket",
    "dataFields": [],
    "dataTags": [],
    "deviceDisplayName": "yolov8_telemetry_01",
    "deviceNameInflux": "yolov8_telemetry_01",
    "deviceTags": [],
    "measurementInflux": "yolov8_telemetry",
    "subDeviceTags": [],
    "tags": "",
    "type": "read",
    "userTags": []
    }
    ],
    "system": {
    "bucketAutoCreate": true,
    "bucketAutoCreateRetention": 3600,
    "debugLevel": "info",
    "forceType": false
    }
    }
    }

    Key fields:

    SectionParameterValueDescription
    inputsbucketInfluxbbrbucketInfluxDB bucket to write into.
    inputsdeviceDisplayNameyolov8_telemetry_01MQTT stream to read — the telemetry stream YOLOv8 publishes to.
    inputsdeviceNameInfluxyolov8_telemetry_01Device identifier inside the InfluxDB measurement.
    inputsmeasurementInfluxyolov8_telemetryInfluxDB measurement that will hold the points.
  2. Click Send App.

Send the Ingester deployment

Send the Ingester deployment

Verify the deployment

The Ingester workload card appears on the Node Details page. When it turns green (Started), the bridge is up.

Ingester workload card

Ingester workload card

Confirm data lands in InfluxDB

  1. Open the InfluxDB web UI at http://<NODE_IP>:8086 and log in.

    ParameterDefault valueSet in
    Port8086Compose Config
    UserbbruserApp Secrets
    PasswordbbrpasswordApp Secrets
    warning

    If your laptop is on a different network than the node, enable the VPN and use the node's VPN IP instead.

  2. Open Data Explorer from the side menu and build a query against the bbrbucket bucket and the yolov8_telemetry measurement.

InfluxDB Data Explorer

InfluxDB Data Explorer

Points appear as YOLOv8 keeps publishing new telemetry messages — the bridge is working.

Summary

The Ingester closes the loop between MQTT and InfluxDB: every YOLOv8 telemetry message now lands as a point in the bbrbucket bucket under the yolov8_telemetry measurement, ready for Grafana to chart in Step 7.