flow.record.adapter.broker
#
Module Contents#
Classes#
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.