معرفی شرکت ها
fastapi-mqtt-1.0.7
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
fastapi-mqtt is extension for MQTT protocol
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | fastapi-mqtt-1.0.7 |
| نام | fastapi-mqtt |
| نسخه کتابخانه | 1.0.7 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | sabuhish |
| ایمیل نویسنده | sabuhi.shukurov@gmail.com |
| آدرس صفحه اصلی | https://github.com/sabuhish/fastapi-mqtt |
| آدرس اینترنتی | https://pypi.org/project/fastapi-mqtt/ |
| مجوز | MIT |
# 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](MQTT.md)
Fatapi-mqtt wraps around [gmqtt](https://github.com/wialon/gmqtt) module. Gmqtt Python async client for MQTT client implementation.
Module has support of MQTT version 5.0 protocol
[](https://raw.githubusercontent.com/sabuhish/fastapi-mqtt/master/LICENSE)
[](https://github.com/sabuhish/fastapi-mqtt/stargazers)
[](https://github.com/sabuhish/fastapi-mqtt/network)
[](https://github.com/sabuhish/fastapi-mqtt/issues)
[](https://pepy.tech/project/fastapi-mqtt)
---
## **Documentation**: [FastApi-MQTT](https://sabuhish.github.io/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)
- Base Settings available with `pydantic` class
- Authetication to broker with credentials
- unsubscribe certain topics and publish to certain topics
### 🔨 Installation
```sh
$ pip install fastapi-mqtt
```
### 🕹 Guide
```python
from fastapi import FastAPI
from fastapi_mqtt import FastMQTT, MQTTConfig
app = FastAPI()
mqtt_config = MQTTConfig()
mqtt = FastMQTT(
config=mqtt_config
)
mqtt.init_app(app)
@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.subscribe("my/mqtt/topic/#")
async def message_to_topic(client, topic, payload, qos, properties):
print("Received message to specific topic: ", 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:
```python
async def func():
mqtt.publish("/mqtt", "Hello from Fastapi") #publishing mqtt topic
return {"result": True,"message":"Published" }
```
Subscribe method:
```python
@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
```python
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](https://github.com/sabuhish/fastapi-mqtt/graphs/contributors).
Contributions of any kind are welcome!
Before you start please read [CONTRIBUTING](https://github.com/sabuhish/fastapi-mqtt/blob/master/CONTRIBUTING.md)
نیازمندی
| مقدار | نام |
|---|---|
| <1.0.0 | fastapi |
| >=0.6.11,<0.7.0 | gmqtt |
| >=1.9.0,<2.0.0 | pydantic |
| >=0.19.0 | uvicorn |
زبان مورد نیاز
| مقدار | نام |
|---|---|
| >=3.7,<4.0 | Python |
نحوه نصب
نصب پکیج whl fastapi-mqtt-1.0.7:
pip install fastapi-mqtt-1.0.7.whl
نصب پکیج tar.gz fastapi-mqtt-1.0.7:
pip install fastapi-mqtt-1.0.7.tar.gz