Object store get streaming data?

[tamis-laan]

I want to put and get large files into the object store that don't fit into memory. From the put signature I can see I can use a BufferedIOBase allowing me to stream the data into the store:

(method) def put(
    name: str,
    data: str | bytes | BufferedIOBase,
    meta: ObjectMeta | None = None
) -> Coroutine[Any, Any, ObjectInfo]

However it looks like I can't get the data out in a streaming manner:

audio = await bucket.get(str(audio_id))
print(type(audio), type(audio.data))

<class 'nats.js.object_store.ObjectStore.ObjectResult'> <class 'bytes'>

As you can see the audio.data property is of type bytes and is completely loaded into RAM memory.

[wallyqs]

here is an example

nats.py/tests/test_js.py

Line 3413 in d6f4f97

obr = await obs.get("tmp", writeinto=f)

[tamis-laan]

@wallyqs

Thnx! I was so focused on the return object I didn't see this option