Skip to content

Apache StreamPipes Python

Output collector

apache/streampipes

Output collector

`OutputCollector(data_stream)` ¶

Collector for output events. The events are published to an output data stream. Therefore, the output collector establishes a connection to the broker.

PARAMETER	DESCRIPTION
`data_stream`	The output data stream that will receive the events. TYPE: `DataStream`

ATTRIBUTE	DESCRIPTION
`publisher`	The publisher instance that sends the data to StreamPipes TYPE: `Publisher`

`collect(event)` ¶

Publishes an event to the output stream.

PARAMETER	DESCRIPTION
`event`	The event to be published. TYPE: `Dict[str, Any]`

RETURNS	DESCRIPTION
`None`

`disconnect()` ¶

Disconnects the broker of the output collector.

RETURNS	DESCRIPTION
`None`

Last update: December 7, 2024