腳本開發 / NSQ

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

本連接器基於 HTTP 協議訪問 NSQ Lookupd，並基於 HTTP 協議發佈消息

DFF.CONN(...) 參數如下：

參數	類型	必須 / 默認值	説明
connector_id	str	必須	連接器 ID

.query(...)

向 NSQ Lookupd 發送 HTTP 請求，參數如下：

參數	類型	必須 / 默認值	説明
method	str	必須	請求方法：GET，POST 等
path	str	None	請求路徑
query	dict	None	請求 URL 參數
body	dict	None	請求體

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

.publish(...)

發佈消息，參數如下：

參數	類型	必須 / 默認值	説明
topic	str	必須	主題
message	str	必須	消息內容