Script Development / NSQ

The NSQ connector action objects mainly provide some methods for operating NSQ.

This connector accesses NSQ Lookupd based on the HTTP protocol and publishes messages based on the HTTP protocol

Parameters for DFF.CONN(...) are as follows:

Parameter	Type	Required / Default Value	Description
connector_id	str	Required	Connector ID

.query(...)

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

Parameter	Type	Required / Default Value	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 Value	Description
topic	str	Required	Topic
message	str	Required	Message content