MQTT和自定义通知服务之间的集成。
mqtt-sentinel的Python项目详细描述
mqtt哨兵
使用自定义规则在mqtt和服务之间进行集成。基于令人敬畏的项目mqttwarn。
安装
…
开始
1.cli
# Create a rule -t topic | -o operator | -e equated
$ msentinel add -c your-conf.ini -t "room/temperature" -o ">=" -e "30"
# Run the sentinel
$ msentinel run -c your-conf.ini
# More info
$ msentinel --help
.ini结构
; your-conf.ini[settings:mqtt]host=localhostport=1883keepalive=60; Optional; [settings:rules]; db_url = sqlite://sentinel.db[output:mqtt] ; Output Servicehost=localhostport=1883keepalive=60topic=device123/broadcast/alarms
1.1输出服务
2.使用库创建应用程序
# app.pyfromsentinelimportSentinelfromsentinel.rulesimportRulefromsentinel.outputimportOutMQTTsentinel=Sentinel()output=OutMQTT(host='localhost',port=1883,topic='app/broadcast/alert')sentinel.set_db()# Use the default SQLite3 database (sentinel.db)sentinel.set_output(output)rule=Rule(topic='device123/room/temperature',operator=">=",equated="31")# If you want create a simple data relay, use:# rule = Rule(topic='device123/room/temperature')sentinel.add_rule(rule)sentinel.start()
$ python app.py
Starting my watch with 1 workers
...
$ python app.py
Starting my watch with 1 workers
...
欢迎加入QQ群-->： 979659372
