The flow simulates IoT data generation and processing using a local Mosquitto MQTT broker.
It includes:
- Periodic message generation with random IDs and timestamps
- Publishing messages to an MQTT topic
- Subscribing to messages and processing based on specific conditions
- CSV logging of generated IDs, published temperature data, and ACK messages
- ID Generator – Generates random IDs and timestamps every 5 seconds.
- CSV Logging – Saves ID logs (
id_log.csv), filtered temperature data (filtered_publish.csv), and ACK logs (ack_log.csv). - Topic Subscription & Processing – Extracts N from ID (
N = ID % 7711) and retrieves related CSV row. - Publish Message Builder – Builds MQTT messages based on CSV row data.
- Node-RED
- Mosquitto MQTT Broker
- ThingSpeak account (for data visualization)
- Node-RED Dashboard nodes