Ingesting time series data into TimescaleDB using MQTT and EMQX | MQTT Timescale Integration

This tutorial will show you how to use MQTT to ingest time series data into TimescaleDB. We will be using the EMQX MQTT broker to publish and subscribe to messages. We will also be using the TimescaleDB database to store the data.

This is a SaaS service for IIoT energy consumption analysis. Each factory has a production line with multiple devices per line. The factory needs to monitor the energy consumption of each device in real time, and analyze the energy consumption of each production line and the entire factory in a certain period of time.

This real-time monitoring and analysis can help factory managers make data-driven decisions, such as identifying equipment failures or abnormal energy consumption, adjusting production schedules to minimize energy consumption, and monitoring and evaluating the effectiveness of energy management measures. To improve energy efficiency and reduce production costs.

1. Init the submodule to get the EMQX Exporter (Optional):

git submodule init
git submodule update

2. Please make sure you have installed the docker, and then running the following commands to start the demo:

docker-compose up -d

You can quickly init submodule and start the demo by using the make command as well.

3. Running the following commands to see the message from MQTTX:

docker logs -f mqttx

4. If you want to view the energy data and EMQX Metrics in Grafana dashboard, you can open http://localhost:3000 in your browser, and login with admin:public

Apache License 2.0