Pengembangan Skrip / Objek Konektor DFF.CONN / NSQ

Objek operasi Konektor NSQ terutama menyediakan beberapa metode untuk mengoperasikan NSQ.

Konektor ini mengakses NSQ Lookupd melalui protokol HTTP, dan menerbitkan pesan melalui protokol HTTP

Parameter DFF.CONN(...) adalah sebagai berikut:

Parameter	Tipe	Wajib / Nilai Default	Deskripsi
connector_id	str	Wajib	ID Konektor
timeout	int/float	10	Waktu tunggu default permintaan HTTP untuk objek operasi saat ini, dalam detik

.query(...)

Mengirim permintaan HTTP ke NSQ Lookupd, dengan parameter sebagai berikut:

Parameter	Tipe	Wajib / Nilai Default	Deskripsi
method	str	Wajib	Metode permintaan, seperti GET, POST; juga dapat ditulis sebagai "GET /nodes"
path	str	None	Jalur permintaan Lookupd yang dimulai dengan /; jika dihilangkan, dipisahkan dari method
query	dict	None	Parameter kueri URL
body	str/bytes/dict	None	Isi permintaan
timeout	int/float	None	Waktu tunggu untuk permintaan ini; jika dihilangkan, menggunakan nilai default objek operasi

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

Jika respons berupa JSON atau XML, objek hasil penguraian dikembalikan; jika tidak, byte mentah dikembalikan; jika kode status HTTP lebih dari atau sama dengan 400, pengecualian dilemparkan.

.publish(...)

Menerbitkan pesan, dengan parameter sebagai berikut:

Parameter	Tipe	Wajib / Nilai Default	Deskripsi
topic	str	Wajib	Topik
message	str/bytes/dict/list/tuple	Wajib	Isi pesan; tipe kontainer akan diserialisasikan terlebih dahulu menjadi JSON
timeout	int/float	None	Waktu tunggu untuk permintaan ini; jika dihilangkan, menggunakan nilai default objek operasi

result = nsq.publish(topic='events', message={'status': 'ok'})

Konektor secara acak memilih satu node dari node produsen yang dikembalikan oleh Lookupd untuk menerbitkan pesan, dan mengembalikan respons HTTP hasil penguraian.