Script Development / NSQ

The NSQ connector object primarily provides methods for operating 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(...)

Send 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(...)

Publish a message. Parameters are as follows:

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