`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, source=None, classification=None, **kwargs)¶

Bases: flow.record.adapter.AbstractWriter

publisher¶

write(r)¶: Write a record.

flush()¶: Flush any buffered writes.

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

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

Bases: flow.record.adapter.AbstractReader

subscriber¶

__iter__()¶: Return a record iterator.

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