-
- GitHub
- GitLab
- Bitbucket
-
By logging in you accept
our terms of service
and privacy policy
Paho's MQTT dev Toolkit
pip install pahotoolkit==0.1.4.2
Welcome to Paho's MQTT Toolkit.
This toolkit if for those who have gone through the documentation of the Paho's MQTT library and its examples and, like me, have felt that the API is somehow off and complicated to onboard applications.
I, personally, like Paho's MQTT library and I don't wish to replace it in anyway. However, I want to write applications that in a way, are familiar to the frameworks I use, e.g., Flask or Sanic. And therefore, abstracting the underlying implementation by using a solid configuration base with a simplified API.
The base configuration of this toolkit uses Paho's event loop implementation by using the start_loop and stop_loop methods and creating a single entrypoint method that accepts different configuration parameters, start_async.
For more examples refer to the examples directory.
import time
from paho.mqtt.client import Client
from pahotoolkit import (
init,
start_async,
stop_async,
subscribe,
json_message,
)
from my_settings import (
HOST,
PORT,
USERNAME,
PASSWORD,
LOG_CONFIG
)
@subscribe('/temperature')
def handle_temperature(mqtt_client: Client, userdata, message):
print(f'Got {message}')
@subscribe('/my/topic')
@json_message() # by default, non-json messages in the topic are ignored
def listen_my_topic(payload: dict, *args, **kwargs):
# todo: do something with the payload
pass
@on_connect()
def client_connected(mqtt_client: Client, *args, **kwargs):
"""Publish something on_connect."""
mqtt_client.publish('/clients', 'Paho\'s MQTT toolkit message!')
# log_config => https://docs.python.org/3/library/logging.config.html#logging.config.dictConfig
# the default MQTT Client uses the default's MQTT Client constructor
# https://github.com/eclipse/paho.mqtt.python#client-1
def main():
client: Client = start_async(host=HOST, port=PORT, # port default to 1883 if not given
username=USERNAME, password=PASSWORD, # optional fields
initialize=False, log_config=LOG_CONFIG) # optional fields
init(client) # only required if initialize=False, else by default is automatically called
while True:
time.sleep(1) # or do something in this thread...
if __name__ == '__main__':
try:
main()
finally:
stop_async()
Arnulfo Solis
The Tidelift Subscription provides access to a continuously curated stream of human-researched and maintainer-verified data on open source packages and their licenses, releases, vulnerabilities, and development practices.
Learn more →Something wrong with this page? Make a suggestion
Export .ABOUT file for this package
Last synced: 2021-02-19 05:34:36 UTC
Login to resync this project