Connect message queue like RabbitMQ, Kafka in Frappe to read log and create doctype for write data

I want to read log from sensor. I push them in a message queue and I want read it and create doctype record to storage data. How to keep connect between frappe and message queue!

Can anyone help me :sob: :sob: :sob:

You’ll need to write custom app. Use python client for the queue backend to write the app.

Example app Sample app to publish and subscribe to MQTT5

I read the sensor values from the IoT device (PLC) with NodeRED and I’ve pushed the data to ERPNext via Frappe REST API.

There are some other tools like Nifi, Streampipes where you can read the sensor values directly from the PLC or you can read and process values from Kafka.