Script Development / NSQ

The NSQ Connector primarily provides methods to interact with NSQ.

This Connector accesses NSQ Lookupd via HTTP protocol and publishes messages via HTTP protocol

DFF.CONN(...) parameters are as follows:

Parameter	Type	Required / Default	Description
connector_id	str	Required	Connector ID

.query(...)

Sends an HTTP request to NSQ Lookupd, parameters are as follows:

Parameter	Type	Required / Default	Description
method	str	Required	Request method: GET, POST, etc
path	str	None	Request path
query	dict	None	Request URL parameters
body	dict	None	Request body

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

.publish(...)

Publishes a message, parameters are as follows:

Parameter	Type	Required / Default	Description
topic	str	Required	Topic
message	str	Required	Message content