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