You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I already have our NATSService used by our FastAPI instance which works great. Up until now just for KV store for some caching. I want to add fastStream as a separate instance which will need to use the common shared code like all services/repos/config/observability etc.
The problem is: I initialise the broker in the NATSProvider which is already being used by other services, but how can I attach that instance to the FastStream instance and attach handlers to it?
I already have our
NATSService
used by our FastAPI instance which works great. Up until now just for KV store for some caching. I want to add fastStream as a separate instance which will need to use the common shared code like all services/repos/config/observability etc.The problem is: I initialise the broker in the
NATSProvider
which is already being used by other services, but how can I attach that instance to the FastStream instance and attach handlers to it?Here my provider:
my container:
here the observability init, this is shared code in the
shared/
folder, used by my FastAPI API and FastStream Worker:And here is the FastStream
app.py
:The text was updated successfully, but these errors were encountered: