erlang 在VerneMQ webhook中传递消息

g6baxovj  于 2022-12-08  发布在  Erlang
关注(0)|答案(1)|浏览(203)

我正在使用VerneMQ插件中的演示webhook(python)
但演示只有auth_on_registerauth_on_publishauth_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?

ffscu2ro

ffscu2ro1#

请看doc:https://docs.vernemq.com/plugindevelopment/webhookplugins您需要做两件事:注册钩子,也就是告诉VerneMQ你想为on_deliver钩子给予一个端点。你可以在vernemq.conf文件中注册,也可以从命令行动态注册。
请注意,使用WebHooks实现的是WebHook后端,而不是Erlang中的插件。您必须在Python后端中添加功能,遵守给定的JSON接口。

相关问题