This is my custom aiomqtt client
Project description
DM-aiomqtt
Urls
Usage
Warning
For correct operation of the client, readwrite access to ping/#
topic is REQUIRED.
Improved system for responding to loss of connection, will use this topic to send ping messages.
(Format of ping messages - topic: ping/[uuid4]
, payload: 1
)
Run in Windows
If you run async code in Windows, set correct selector
import asyncio
import sys
if sys.platform == "win32":
asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
Example
from dm_aiomqtt import DMAioMqttClient
import asyncio
# create handler for 'test' topic
async def test_topic_handler(publish: DMAioMqttClient.publish, topic: str, payload: str) -> None:
print(f"Received message from {topic}: {payload}")
await publish("test/success", payload=True)
async def main():
# create client
mqtt_client = DMAioMqttClient("localhost", 1883, "username", "password")
# add handler for 'test' topic
mqtt_client.add_topic_handler("test", test_topic_handler)
# start connection
await mqtt_client.start()
# publish
await mqtt_client.publish("test", payload="Hello World!", sent_logging=True)
# other code (for example, endless waiting)
await asyncio.Event().wait()
if __name__ == "__main__":
asyncio.run(main())
Set custom logger
If you want set up custom logger
from dm_aiomqtt import DMAioMqttClient
# create custom logger
class MyLogger:
def debug(self, message):
pass
def info(self, message):
pass
def warning(self, message):
print(message)
def error(self, message):
print(message)
# set up custom logger for all clients
DMAioMqttClient.set_logger(MyLogger())
Publish method parameters
Parameter | Type | Default Value | Description |
---|---|---|---|
topic |
str |
(required) | Topic name |
payload |
str |
"DEBUG" |
Content to send |
qos |
0 | 1 | 2 |
True |
MQTT QoS |
payload_to_json |
bool | "auto" |
True |
Whether to convert content to JSON |
sent_logging |
bool |
False |
Whether to print the sending notification |
warn_logging |
bool |
False |
Whether to print a send error warning |
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
dm-aiomqtt-0.3.2.tar.gz
(4.1 kB
view hashes)
Built Distribution
Close
Hashes for dm_aiomqtt-0.3.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cba3751c180bba2a71a3bb752cd96f87f55aa7559a0ebcbf075c89ec241d44e6 |
|
MD5 | 465f4b2e1f8bb8af92775095cb582828 |
|
BLAKE2b-256 | 7bfbda888c42eb90815b0647d7ebe71f150b178bf0dce0ffcca0c2a24ee10462 |