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.