`flow.record.adapter.broker`¶

Module Contents¶

Classes¶

`BrokerWriter`
`BrokerReader`

Attributes¶

flow.record.adapter.broker.__usage__ = Multiline-String¶

Show Value

"""
PubSub adapter using flow.broker
---
Write usage: rdump -w broker+tcp://[IP]:[PORT]
Read usage: rdump broker+tcp://[IP]:[PORT] -s True
"""

class flow.record.adapter.broker.BrokerWriter(uri: str, source: str | None = None, classification: str | None = None, **kwargs)¶

Bases: flow.record.adapter.AbstractWriter

publisher = None¶

source = None¶

classification = None¶

write(r: flow.record.base.Record) → None¶: Write a record.

flush() → None¶: Flush any buffered writes.

close() → None¶: Close the Writer, no more writes will be possible.

class flow.record.adapter.broker.BrokerReader(uri: str, name: str | None = None, selector: str | None = None, **kwargs)¶

Bases: flow.record.adapter.AbstractReader

subscriber = None¶

subscription¶

__iter__() → collections.abc.Iterator[flow.record.base.Record]¶: Return a record iterator.

close() → None¶: Close the Reader, can be overriden to properly free resources.