`flow.record.adapter.archive`¶

Module Contents¶

Classes¶

`ArchiveWriter`
`ArchiveReader`

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: str, **kwargs)¶

Bases: flow.record.adapter.AbstractWriter

writer = None¶

path¶

write(r: flow.record.base.Record) → None¶: Write a record.

flush() → None¶: Flush any buffered writes.

close() → None¶: Close the Writer, no more writes will be possible.

class flow.record.adapter.archive.ArchiveReader(path: str, **kwargs)¶: Bases: flow.record.adapter.AbstractReader