flow.record.adapter.archive#

Module Contents#

Classes#

Attributes#

flow.record.adapter.archive.__usage__ = Multiline-String#
Show Value
"""
Record archiver adapter, writes records to YYYY/mm/dd directories (writer only)
---
Write usage: rdump -w archive://[PATH]
[PATH]: path to folder
"""
class flow.record.adapter.archive.ArchiveWriter(path, **kwargs)#

Bases: flow.record.adapter.AbstractWriter

writer#
write(r)#

Write a record.

flush()#

Flush any buffered writes.

close()#

Close the Writer, no more writes will be possible.

class flow.record.adapter.archive.ArchiveReader(path, **kwargs)#

Bases: flow.record.adapter.AbstractReader