MQTT REST Bridge is a package to bridge between MQTT and REST protocols. We call APIs make multiple Python projects connected with it.
poetry add git+https://github.com/NubeIO/mqtt-rest-bridge@masterpoetry remove mqtt-rest-bridgefrom mrb.brige import MqttRestBridge
from mrb.setting import MqttSetting
def callback():
print('callback...')
MqttRestBridge(port=8080, mqtt_setting=MqttSetting(), callback=callback)Example to GET value from slave:
from mrb.mapper import api_to_slave_topic_mapper
from mrb.message import Response, HttpMethod
response: Response = api_to_slave_topic_mapper(slave_global_uuid=f'<uuid>',
api=f'/api/generic/networks',
http_method=HttpMethod.GET)Example to POST value to slave:
import json
from mrb.mapper import api_to_slave_topic_mapper
from mrb.message import Response, HttpMethod
body: json = {
"name": "generic_network",
"enable": True,
"history_enable": True
}
response: Response = api_to_slave_topic_mapper(slave_global_uuid=f'<uuid>',
api=f"/api/generic/networks",
body=body,
headers={},
http_method=HttpMethod.POST)Example to DELETE value on slave:
from mrb.mapper import api_to_slave_topic_mapper
from mrb.message import Response, HttpMethod
response: Response = api_to_slave_topic_mapper(slave_global_uuid=f'<uuid>',
api=f'/api/generic/networks/b7a23aa5-b8a1-4a0f-9acf-4fb011bce50e',
http_method=HttpMethod.DELETE)Example to GET value from master:
from mrb.mapper import api_to_master_topic_mapper
from mrb.message import Response, HttpMethod
response: Response = api_to_master_topic_mapper(api=f'/api/generic/networks',
http_method=HttpMethod.GET)Example to GET values on master from slaves:
from mrb.mapper import api_to_slaves_broadcast_topic_mapper
from mrb.message import Response, HttpMethod
response: Response = api_to_slaves_broadcast_topic_mapper(api=f'/api/system/ping',
http_method=HttpMethod.GET)is_bridge(request.args) # True if MQTT > REST, else REST
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent