脚本开发 / NSQ

NSQ 连接器操作对象主要提供一些操作 NSQ 的方法。

本连接器基于 HTTP 协议连接到 NSQ Lookupd，并基于 HTTP 协议发布消息

DFF.CONN(...)参数如下：

参数	类型	必须/默认值	说明
connector_id	str	必须	连接器 ID

.query(...)

query(...)方法用于向 NSQ Lookupd 发送 HTTP 请求，参数如下：

参数	类型	必须/默认值	说明
method	str	必须	请求方法：GET，POST等
path	str	None	请求路径
query	dict	None	请求 URL 参数
body	dict	None	请求体

示例如下：

result = nsq.query('GET', '/nodes')

.publish(...)

publish(...)方法用于发布消息，参数如下：

参数	类型	必须/默认值	说明
topic	str	必须	主题
message	str	必须	消息内容