Reduct Storage Python SDK v0.3.0이 출시되었습니다.
3947 단어 pythonnewsreductstorage
Reduct Storage Python SDKv0.3.0가 출시되었습니다.
최신 Reduct Storage HTTP API v0.6.0을 지원하지만 가장 중요한 변화는 데이터 스트리밍입니다. 예제와 함께 어떻게 작동하는지 봅시다!
전제 조건
이 게시물은 튜토리얼이 아니며, 여러분이 Reduct Storage 인스턴스를 시작하고 버킷을 생성하는 방법을 알고 있다고 가정합니다. 모르는 경우 도움이 될 수 있는 몇 가지 링크:
청크로 데이터 읽기
이 릴리스에서는 비동기 반복자를 사용하여 청크별로 데이터를 읽는 새로운 방법
Bucket.read_by
을 도입했습니다. with open("file.bin", "wb") as file:
async for chunk in bucket.read_by("entry-1", chunk_size=1024):
file.write(chunk)
다운로드할 큰 레코드가 있거나 동시에 많은 레코드를 읽어야 하는 경우 유용할 수 있습니다.
청크로 데이터 쓰기
청크별로 데이터를 쓰는 것은 조금 더 까다로울 수 있습니다. 먼저 비동기 반복자를
Bucket.write
메서드에 전달해야 합니다. 그런 다음 쓰고 있는 데이터의 크기를 지정해야 합니다. 스토리지 엔진은 content-lenght
헤더를 필요로 하며 사용자는 기록된 데이터의 크기를 미리 알고 있어야 합니다.file_path = Path("./path/to/file")
async def sender():
with open(file_path, "br") as file:
while True:
chunk = file.read(1024)
if not chunk:
break
yield chunk
content_length = file_path.stat().st_size
await bucket.write("entry-1", sender(), content_length=content_length)
관심이 있는 경우 스토리지 엔진here에 대해 자세히 알아보십시오.
표지 이미지 디자인 by roserodionova/Freepik
Reference
이 문제에 관하여(Reduct Storage Python SDK v0.3.0이 출시되었습니다.), 우리는 이곳에서 더 많은 자료를 발견하고 링크를 클릭하여 보았다 https://dev.to/reduct-storage/streaming-data-with-new-reduct-storage-python-sdk-307d텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
우수한 개발자 콘텐츠 발견에 전념 (Collection and Share based on the CC Protocol.)