for example:
from asgiref.sync import async_to_sync as a2s
from channels.layers import get_channel_layer
from channels_mqtt import settings
event = {"type": settings.MQTT_PUBLISH, "text": {"topic": topic, "payload":
payload, "qos": qos, "retain": retain}}
a2s(channel_layer.send)(channel, event)
--
You received this message because you are subscribed to the Google Groups
"Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/django-users.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/9baad777-df4b-4c97-b9c7-4f1c1558a044%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
