我正在使用VerneMQ插件中的演示webhook(python)
但演示只有auth_on_register
、auth_on_publish
和auth_on_subscribe
我的信息已经通过了所有的链路,但是潜艇看不到从酒吧传来的信息
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只在erlang https://github.com/vernemq/vernemq_dev/blob/master/src/on_deliver_hook.erl中找到
问:在python语言中有没有方法、函数把消息传递给sub?
1条答案
按热度按时间ffscu2ro1#
请看doc:https://docs.vernemq.com/plugindevelopment/webhookplugins您需要做两件事:注册钩子,也就是告诉VerneMQ你想为
on_deliver
钩子给予一个端点。你可以在vernemq.conf
文件中注册,也可以从命令行动态注册。请注意,使用WebHooks实现的是WebHook后端,而不是Erlang中的插件。您必须在Python后端中添加功能,遵守给定的JSON接口。