Broker handler

SupportedBroker

Bases: Enum

Enum for the supported brokers.

UnsupportedBrokerError(message)

Bases: Exception

Exception if a broker isn't implemented yet.

get_broker(data_stream)

Derive the broker for the given data stream.

PARAMETER	DESCRIPTION
data_stream	Data stream instance from which the broker is inferred TYPE: DataStream

RETURNS	DESCRIPTION
broker	The corresponding broker instance derived from data stream. TYPE: Broker

RAISES	DESCRIPTION
UnsupportedBrokerError	Is raised when the given data stream belongs to a broker that is currently not supported by StreamPipes Python.