ZMQSink
Publishes metadata on a ZMQ socket.
This module contains the ZMQ sink
. It is responsible for connecting to a ZMQ
socket, and publishing the metadata. Depending on the configuration of the
connected sources
and pipeline elements
the metadata may contain an encoded
JPEG image, or a presentation timestamp for synchronizing the MP4 Proxy Stream.
For a detailed description, please refer to: Data Publishing Endpoint (PUB-SUB) in the ZMQ API.
For a detailed example, please refer to Subscriber Example.
Examples:
REST API:
WIP
Configuration File:
Publish all channels:
sink:
- address: tcp://*:22952
- filter: []
- type: zmq
Publish channels 1 and 2:
```yaml
sink:
- address: tcp://*:22952
- filter: [1,2]
- type: zmq
ZMQSink Objects
class ZMQSink(SinkNode)
Publishes metadata on a ZMQ socket.
Attributes:
sink_address
str - The address of the ZMQ socket.sink_filter
function - A function that filters the metadata.
Examples:
sink = ZMQSink("tcp://*:22952", lambda x: True)