fastapi-mqtt
MQTT is a lightweight publish/subscribe messaging protocol designed for M2M (machine to machine) telemetry in low bandwidth environments. Fastapi-mqtt is the client for working with MQTT.
For more information about MQTT, please refer to here: MQTT
Fatapi-mqtt wraps around gmqtt module. Gmqtt Python async client for MQTT client implementation. Module has support of MQTT version 5.0 protocol
Documentation: FastApi-MQTT
The key feature are:
MQTT specification avaliable with help decarator methods using callbacks:
-
on_connect()
-
on_disconnect()
-
on_subscribe()
-
on_message()
-
subscribe(topic_names)
-
Base Settings available with
pydanticclass -
Authetication to broker with credentials
-
unsubscribe certain topics and publish to certain topics
🔨
Installation
$ pip install fastapi-mqtt
🕹
Guide
from fastapi import FastAPI
from fastapi_mqtt import FastMQTT, MQTTConfig
app = FastAPI()
mqtt_config = MQTTConfig()
mqtt = FastMQTT(
config=mqtt_config
)
@app.on_event("startup")
async def startapp():
await mqtt.connection()
@app.on_event("shutdown")
async def shutdown():
await mqtt.client.disconnect()
@mqtt.on_connect()
def connect(client, flags, rc, properties):
mqtt.client.subscribe("/mqtt") #subscribing mqtt topic
print("Connected: ", client, flags, rc, properties)
@mqtt.on_message()
async def message(client, topic, payload, qos, properties):
print("Received message: ",topic, payload.decode(), qos, properties)
@mqtt.on_disconnect()
def disconnect(client, packet, exc=None):
print("Disconnected")
@mqtt.on_subscribe()
def subscribe(client, mid, qos, properties):
print("subscribed", client, mid, qos, properties)
Publish method:
async def func():
await mqtt.publish("/mqtt", "Hello from Fastapi") #publishing mqtt topic
return {"result": True,"message":"Published" }
Subscribe method:
@mqtt.on_connect()
def connect(client, flags, rc, properties):
mqtt.client.subscribe("/mqtt") #subscribing mqtt topic
print("Connected: ", client, flags, rc, properties)
Changing connection params
mqtt_config = MQTTConfig(host = "mqtt.mosquito.org",
port= 1883,
keepalive = 60,
username="username",
password="strong_password")
mqtt = FastMQTT(
config=mqtt_config)
Contributing
Fell free to open issue and send pull request.
Thanks To Contributors. Contributions of any kind are welcome!
Before you start please read CONTRIBUTING
1.3k Dec 31, 2022
379 Jan 03, 2023
124 Nov 26, 2022
42 Dec 21, 2022
950 Jan 08, 2023
3 Apr 08, 2022
14 Jan 06, 2022
31 Nov 25, 2022
6 Nov 14, 2022
318 Dec 31, 2022
104 Dec 23, 2022
3 Dec 05, 2022
768 Dec 22, 2022
4 Mar 16, 2022
9 Nov 15, 2022
4 Jun 24, 2022
1.5k Jan 04, 2023
551 Dec 24, 2022
551 Jan 08, 2023
91 Jan 05, 2023