一种简单的消息队列管道控制器
gabb的Python项目详细描述
<;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a;a SVG?
<;
<;a>;
<;
<;
<;
<;
<;lt;img src=“https://badge.fury.io/py/py/gabby/gabby.svg/gt;
<;
<;
<;
<;
<;
<;
<;a;a a a a a
python-gabby
mqtt和mqtt-sn管道的简单控制器,使用mosquito和rsmb
请初始化mosquitto或rsmb服务器。
\数据:{message.data}')
return[]
controller.add_gabby(打印机gabby)controller.run()
```
主题a=topic('queue/a','i')
主题b=topic('queue/b','i')
g=gabbby([topic[topic[topic[topic[topic[topic[topic[topic[topic[topic[topic[topic[u a])
data=(1,)
g.send(消息(数据,g.out输出相关主题))
```` `
` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` ` printergabby(gabby):
定义转换(self,消息):
打印(F'Arrived!数据:{message.data}')
return[]
controller.add_gabbby(printer_gabbby)
>controller.run()
<35<35<35<
class loggergabbby(gabbby)从gabby导入日志
/>定义转换(自我,消息):
日志记录。调试(f“已到达!数据:{message.data}“
def setup_logging(level):
”“
setup logging level
”“
logging.basicconfig(
format='%(levelname)s:%(message)s',
level=getattr(logging,
>如果安装日志(debug)设置
controller=controller()
topic a=topic('qa','i','udp')
topic f=topic('qb','i','udp')
topic b=topic cf=topic('qb','i','udp')
topic c=topic topic c=topic话题('que队列/队列/队列/队列/队列/a,'i,'i','tcp’=topic('queue/b',‘I’,‘TCP’)
logger-gabbby=loggergabbby(
[topic-a,topic-f,topic-b,topic-c,topic-d,topic-e],
[topic-a,topic-f,topic-f,topic-b,topic-c,topic-d,topic-e],
controller.add gabbby(logger-gabbby)controller(logger-gabbby)controller.run()
<是的