Support the binary store API (alpha) from Dapr 1.19
I maintainer di solito rispondono entro 2 giorni
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 35/100
Direzione di ricerca
Start by regenerating the protos with tools/regen_grpcclient.sh (DAPR_BRANCH=release-1.19) and confirm binarystore.proto appears. Then study the existing gRPC methods in dapr/clients/grpc/client.py and dapr/aio/clients/grpc/client.py to see how client-streaming and server-streaming calls are wrapped. Done means set, get and delete *_alpha1 methods exist in both clients, with tests and an examples/ app that uses binarystore.in-memory.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
Summary
Dapr 1.19 adds the binary store building block as an alpha API. An app uses it to store, read and delete files as byte streams through a binary store component. The Python SDK has no client API for it yet. The .NET SDK already supports it, so its implementation is a reference for this work.
Runtime API
gRPC, in the Dapr service (binarystore.proto):
SetBinaryFileAlpha1is a client stream. The first message must containinitial_requestwithcomponent_name,file_nameandoverwrite, and it must arrive within 5 seconds. Each later message contains onepayloadchunk (common.v1.StreamPayload). Itsseqstarts at 0 and goes up by 1 for each chunk. Ifoverwriteis false (the default), the call fails when the file exists. Ifoverwriteis true, the call replaces the file.GetBinaryFileAlpha1returns a server stream ofpayloadchunks of up to 32 KiB, withseqfrom 0.DeleteBinaryFileAlpha1is a unary call.
HTTP, on /v1.0-alpha1/binarystore/{name}/{fileName}:
PUTstores the request body and replaces an existing file.POSTstores the request body, and returns 409 if the file exists.GETreturns the file asapplication/octet-stream.DELETEdeletes the file.
Components in 1.19: binarystore.aws.s3, binarystore.azure.blobstorage, binarystore.azure.datalake, binarystore.gcp.bucket, binarystore.oci.objectstorage and binarystore.in-memory.
Reference: the .NET SDK
- dapr/dotnet-sdk#1933 (merged) adds the
Dapr.BinaryStore.*packages.IDaprBinaryStoreClienthas these methods:SetBinaryFileAsync, from a stream or a byte buffer, withoverwriteand a 32 KiB default chunk sizeGetBinaryFileChunksAsync,GetBinaryFileAsync(to a stream) andGetBinaryFileBytesAsyncDeleteBinaryFileAsync
- dapr/dotnet-sdk#1935 (in review) adds an example app.
- dapr/docs#5388 (in review) adds the .NET SDK docs.
Related links: the proposal (dapr/proposals#88), the runtime implementation (dapr/dapr#10367) and the components (dapr/components-contrib#4559 and dapr/components-contrib#4637). dapr/dotnet-sdk#1934 stores workflow data references in the binary store. That is a separate feature (dapr/dapr#8706), and it is not part of this issue.
Scope
- Generate the protos from Dapr 1.19 with
tools/regen_grpcclient.sh(for exampleDAPR_BRANCH=release-1.19). The script takes everyruntime/v1proto, so it picks upbinarystore.proto.mainandrelease-1.19do not have it yet. - Add set, get and delete
*_alpha1methods to the sync client (dapr/clients/grpc/client.py) and the async client (dapr/aio/clients/grpc/client.py). Set takes bytes or a file-like object and anoverwriteflag. Get returns bytes or an iterator of chunks. - Send the upload chunks in order after the initial request, with
seqfrom 0. - Add tests, and an example in
examples/that uses thebinarystore.in-memorycomponent. - Add docs to the Python SDK section of dapr/docs.
The API is alpha, so its names and behavior can change in a later release.
- Lingua principale
- Python
- Stelle
- 274
- Fork
- 157
- Merge medio
- 5g 15h
- PR unite (30g)
- 70
Preparare l'ambiente
Avvia il container di sviluppo del progetto nel browser, con il tuo account GitHub.
- Nessun Dockerfile né file Docker Compose
- Ha un modello di pull request
- Leggi la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di dapr/python-sdk
-
SDK Alignment of Workflow ExamplesForse di nuovo libera Una pull request per questa issue è stata chiusa senza essere unita. Apertadapr-ext-workflow good first issue kind/enhancement P2
Difficoltà 2/5 1-2 giorni Idoneità per principianti 72/100
dapr/python-sdk#853 · 4 commenti ·
I maintainer di solito rispondono entro 2 giorni
-
ci/release-failure release
Difficoltà 2/5 1-3 ore Idoneità per principianti 49/100
dapr/python-sdk#1311 ·
I maintainer di solito rispondono entro 2 giorni
-
[WORKFLOW SDK FEATURE REQUEST] Retry WaitForInstanceCompletion/Start on a server-sent CANCELLEDApertadapr-ext-workflow kind/enhancement
Difficoltà 4/5 3-5 giorni Idoneità per principianti 55/100
dapr/python-sdk#1246 ·
I maintainer di solito rispondono entro 2 giorni
-
[BUG] subscribe_with_handler stops silently: async task can die or be collected, sync retry path exits, handler errors reconnect the streamForse già presa @CasperGN l’ha presa 24 giorni fa. Apertakind/bug
Difficoltà 4/5 3-5 giorni Idoneità per principianti 65/100
dapr/python-sdk#1233 ·
I maintainer di solito rispondono entro 2 giorni
-
[BUG] Configuration subscription stops permanently after the daprd sidecar restartsForse già presa @CasperGN l’ha presa 21 giorni fa. Apertakind/bug
Difficoltà 4/5 3-5 giorni Idoneità per principianti 68/100
dapr/python-sdk#1232 ·
I maintainer di solito rispondono entro 2 giorni
Tutte le issue di dapr/python-sdk
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 83/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 86/100
google-ai-edge/litert-torch#1346 ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
geneontology/gocam-py#272 ·
-
pushed_authorization_request sends list authorization_details as a Python reprForse già presa @RaphaelFakhri l’ha presa oggi. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
auth0/auth0-python#903 ·
I maintainer di solito rispondono entro 1 giorno