指令碼開發 / 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	必須	訊息內容