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.