search

dapr / python-sdk

Dapr SDK for Python
Apache License 2.0
232 stars 127 forks source link

Add Streaming Subscription Support #730

Closed JoshVanL closed 2 weeks ago

JoshVanL commented 4 months ago

Dapr v1.14 adds support for streaming subscriptions which allows for dynamically subscribing to pubsub topics over a bi-directional gRPC stream. This API is exposed via the SubscribeTopicEventsAlpha1 gRPC API.

On first call, the client sends an InitialRequest containing the pubsub, topic name, etc. From then on, topic event messages are sent from daprd to the client over the stream. The client reports the processing status of this message back to daprd. A message will not be considered processed until the client has responded with this status. There can be multiple in-flight topic messages. Daprd unsubscribes from the topic when the stream is closed.

https://github.com/dapr/go-sdk/pull/578/ is a reference implementation for the go-sdk.

berndverst commented 3 months ago

You used the wrong issue template. :)