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 = None¶
- source¶
- classification¶
- write(r)¶
Write a record.
- flush()¶
Flush any buffered writes.
- close()¶
Close the Writer, no more writes will be possible.