pythia.event_stream.log

Memory-backed event stream storage.

class pythia.event_stream.log.Backend(uri: str)

Bases: Backend

Simple event stream client to dump incoming data using logs.

Initialize a backend from its uri.

Parameters:

uri – connection string.

_abc_impl = <_abc_data object>

_logger: _DumpLogger | None = None

connect() → None

Fetch stream-specific deque from global container.

property logger: _DumpLogger

Internal logger lazy-loader.

Returns:

Initialized logger.

post(data) → None

Append an element into the deque.

Parameters:

data – the data to append. Can be any python object.