save_zmq

Sends bytes as ZeroMQ messages.

save_zmq [endpoint:str, listen=bool, connect=bool, monitor=bool]

Description

The save_zmq operator sends bytes as a ZeroMQ message via a PUB socket.

Indpendent of the socket type, the save_zmq operator supports specfiying the direction of connection establishment with listen and connect. This can be helpful to work around firewall restrictions and fit into broader set of existing ZeroMQ applications.

With the monitor option, you can activate message buffering for TCP sockets that hold off sending messages until at least one remote peer has connected. This can be helpful when you want to delay publishing until you have one connected subscriber, e.g., when the publisher spawns before any subscriber exists.

endpoint: str (optional)

The endpoint for connecting to or listening on a ZeroMQ socket.

Defaults to tcp://127.0.0.1:5555.

listen = bool (optional)

Bind to the ZeroMQ socket.

Defaults to true.

connect = bool (optional)

Connect to the ZeroMQ socket.

Defaults to false.

monitor = bool (optional)

Monitors a 0mq socket over TCP until the remote side establishes a connection.

Examples

Publish events by connecting to a PUB socket

from {x: 42}
write_csv
save_zmq connect=true

See Also

load_zmq