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
: