我正在使用来自VerneMQ插件的演示webhooks(python)
但是演示只有auth_on_register
、auth_on_publish
和auth_on_subscribe
我的消息已经通过了所有的链接,但是sub看不到来自酒吧的消息
hook: auth_on_register
data: {'peer_addr': '192.168.122.1', 'peer_port': 52363, 'mountpoint': '', 'client_id': 'quan-client', 'username': 'quan1', 'password': '123', 'clean_session': True}
127.0.0.1:58109 - - [25/May/2020 02:40:49] "HTTP/1.1 POST /" - 200 OK
hook: auth_on_register
data: {'peer_addr': '192.168.122.1', 'peer_port': 46091, 'mountpoint': '', 'client_id': 'quan-client', 'username': 'quan1', 'password': '123', 'cle
an_session': True}
127.0.0.1:60003 - - [25/May/2020 02:40:49] "HTTP/1.1 POST /" - 200 OK
hook: auth_on_publish
data: {'username': 'quan1', 'mountpoint': '', 'client_id': 'quan-client', 'qos': 0, 'topic': 'a', 'payload': 'dGVzdA==', 'retain': False}
127.0.0.1:58109 - - [25/May/2020 02:40:49] "HTTP/1.1 POST /" - 200 OK
hook: auth_on_subscribe
data: {'username': 'quan1', 'mountpoint': '', 'client_id': 'quan-client', 'topics': [{'topic': 'a', 'qos': 0}]}
127.0.0.1:58109 - - [25/May/2020 02:40:49] "HTTP/1.1 POST /" - 200 OK
我想我错过了on_deliver
链,但我在python中找不到它的任何示例,github仅在erlanghttps://github.com/vernemq/vernemq_dev/blob/master/src/on_deliver_hook.erl中
问:是否有任何方法、函数可以用python语言将消息传递给sub
请看一下文件:https://docs.vernemq.com/plugindevelopment/webhookplugins 您需要做两件事:注册钩子,即告诉VerneMQ您想要为
on_deliver
钩子指定一个端点。您可以在vernemq.conf
文件中注册,也可以从命令行动态注册请注意,使用WebHook可以实现WebHook后端,而不是Erlang中的插件。您必须在Python后端中添加功能,并考虑给定的JSON接口
相关问题 更多 >
编程相关推荐