flow.record.adapter.jsonfile#

Module Contents#

Classes#

Attributes#

flow.record.adapter.jsonfile.__usage__ = Multiline-String#
Show Value
"""
JSON adapter
---
Write usage: rdump -w jsonfile://[PATH]?indent=[INDENT]&descriptors=[DESCRIPTORS]
Read usage: rdump jsonfile://[PATH]
[PATH]: path to file. Leave empty or "-" to output to stdout
[INDENT]: optional number of identation. Omit "indent" field value for jsonlines output
[DESCRIPTORS]: optional boolean. If false, don't output record descriptors (default: true)
"""
class flow.record.adapter.jsonfile.JsonfileWriter(path, indent=None, descriptors=True, **kwargs)#

Bases: flow.record.adapter.AbstractWriter

fp#
packer_on_new_descriptor(descriptor)#
write(r)#

Write a record.

flush()#

Flush any buffered writes.

close()#

Close the Writer, no more writes will be possible.

class flow.record.adapter.jsonfile.JsonfileReader(path, selector=None, **kwargs)#

Bases: flow.record.adapter.AbstractReader

fp#
close()#

Close the Reader, can be overriden to properly free resources.

__iter__()#

Return a record iterator.