Send messages from application server to MQTT broker

[edigiacomo]

2 possible implementation:

Channel

Channel mqtt.pub with the following keys:

• topic
• payload
• qos
• host?
• port?

asgimqtt should read the messages from this channel and send them to MQTT broker. asgimqtt is also a subscriber, so the message will be received from the broker and sent to mqtt.sub.

There's a problem: the channel must be consumed by asgimqtt

MQTT broker

The message is sent to the MQTT broker (similar to sending an email in ASGI definition), e.g.

import paho.mqtt.publish as publish

publish.single("/path/to/topic", "payload", hostname="localhost")