MQTT 🚠 InfluxDB

MQTT consumer that ingests directly into InfluxDB

Data schema

This MQTT to InfluxDB forwarder work in a way, that you publish JSON data on topics. The topics that you use must follow a common prefix, that your specify with the MQTT_TOPIC_PREFIX environment variable. The MQTT will be used as the InfluxDB measurement name within the database specified in INFLUXDB_DATABASE. You must adhere to the following JSON format.

JSON message schema

Key	Value
timestamp	A microseconds timestamp
tags	Specify InfluxDB tags as a JSON object. Tags are indexed fields.
fields	Specify InfluxDB fields as a JSON object.

Example JSON message:

{
	timestamp: 1544292348745,
	tags: { device: "car4" },
	fields: {
		latitude: 50.1234223,
		longitude: 7.34543,
		altitude: 323,
		velocity: 342
	}
}

Run via Docker

The MQTT InfluxDB ingester can be run via Docker. The docker image is hosted on Docker Hub:

hub.docker.com/r/brueggemannthomas/mqtt-influxdb

Environment Variables

The Docker container uses the following environment variables to be configured:

Environment Variable	Description
INFLUXDB_HOST	Set a hostname to connect to your InfluxDB database
INFLUXDB_PORT	Portnumber of InfluxDB setup
INFLUXDB_USERNAME	InfluxDB username
INFLUXDB_PASSWORD	InfluxDB password
INFLUXDB_DATABASE	Name of the database that your MQTT messages will be written to
MQTT_URI	URI to your MQTT broker, e.g. mqtt://io.your-domain.com Must adhere to https://github.com/mqttjs/MQTT.js#mqttconnecturl-options
MQTT_PORT	Portnumber of MQTT broker
MQTT_USERNAME	MQTT broker username
MQTT_PASSWORD	MQTT broker password
MQTT_TOPIC_PREFIX	The prefix of the topics to listen to. As an example, sensor/ will listen to all topics that start with sensor/, e.g. sensor/cpu and sensor/mem would be captured. Must end with a slash