Encode and decode concatenated objects as streams
Project description
Encoding a JSON iterator into a stream:
def gen_records(): yield b'{"foo": "bar"}' yield b'{"baz": [1, 2, 3]}' stream = streamcat.iterator_to_stream(gen_records()) # `stream` can then be used just like any other `io.RawIOBase` with open('/tmp/jsoncat', 'wb') as destination: shutil.copyfileobj(stream, destination)
Decoding a stream into a generator:
decoder = json.JSONDecoder() with open('/tmp/jsoncat', 'rb') as source: records = streamcat.stream_to_iterator(source, decoder) for record in records: print(record)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
streamcat-0.2.1.tar.gz
(4.1 kB
view hashes)
Built Distribution
Close
Hashes for streamcat-0.2.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | fcfde8809c24e490ff8414261f7475a695c0d34a6497fbc56a719a0baf1e4147 |
|
MD5 | b901e1d472488420cb32fcf0c1efb408 |
|
BLAKE2-256 | 7ace34ef9ee80186316de469f460b0ccbbc9c648bb26b8d7216ec163e4b7b7bc |