flow.record.adapter.mongo
¶
Module Contents¶
Classes¶
Functions¶
Attributes¶
- flow.record.adapter.mongo.__usage__ = Multiline-String¶
Show Value
""" MongoDB adapter --- Write usage: rdump -w mongo://[IP]:[PORT]/[DBNAME]/[COLLECTION] Read usage: rdump mongo://[IP]:[PORT]/[DBNAME]/[COLLECTION] [IP]:[PORT]: ip and port to a mongodb instance [DBNAME]: database name to write to or read from [COLLECTION]: collection to write to or read from """
- flow.record.adapter.mongo.parse_path(path)¶
- class flow.record.adapter.mongo.MongoWriter(path, key=None, **kwargs)¶
Bases:
flow.record.adapter.AbstractWriter
- client¶
- write(r)¶
Write a record.
- flush()¶
Flush any buffered writes.
- close()¶
Close the Writer, no more writes will be possible.
- class flow.record.adapter.mongo.MongoReader(path, selector=None, **kwargs)¶
Bases:
flow.record.adapter.AbstractReader
- client¶
- close()¶
Close the Reader, can be overriden to properly free resources.
- __iter__()¶
Return a record iterator.