Modern-DI integration for FastStream.
Full guide: FastStream integration docs
Installation
uv add modern-di-faststream # or: pip install modern-di-faststream
Usage
setup_di registers the container and installs a broker middleware that builds a per-message child container; FromDI resolves a provider (or type) into a subscriber parameter.
import dataclasses
import faststream
from faststream.nats import NatsBroker
from modern_di import Container, Group, Scope, providers
from modern_di_faststream import FromDI, setup_di
@dataclasses.dataclass(kw_only=True)
class Settings:
debug: bool = True
@dataclasses.dataclass(kw_only=True)
class GreetingHandler:
settings: Settings # auto-injected by type
class Dependencies(Group):
settings = providers.Factory(scope=Scope.APP, creator=Settings)
handler = providers.Factory(scope=Scope.REQUEST, creator=GreetingHandler)
broker = NatsBroker()
app = faststream.FastStream(broker)
container = Container(groups=[Dependencies], validate=True)
setup_di(app, container)
@broker.subscriber("greetings")
async def handle(name: str, handler: GreetingHandler = FromDI(Dependencies.handler)) -> None:
print(name, handler.settings.debug)
The current StreamMessage is resolvable within DI via the pre-built faststream_message_provider context provider.
API
setup_di(app, container)— stores the container in the app context, registers startup/shutdown lifecycle hooks (reopen on startup, close after shutdown), and adds the DI middleware to the brokerFromDI(dependency, *, use_cache=True, cast=False)— FastStreamDependsthat resolves a provider (or type) from the per-message child containerfetch_di_container(app)— returns the app-scoped container from the app contextfaststream_message_provider—ContextProviderfor the currentfaststream.StreamMessage
📦 PyPI
📝 License
Part of modern-python
Built on modern-di, a dependency-injection framework with IoC container and scopes.
Browse the full list of templates and libraries in
modern-python — see the org profile for the categorized index.
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file modern_di_faststream-3.0.0.tar.gz.
File metadata
- Download URL: modern_di_faststream-3.0.0.tar.gz
- Upload date:
- Size: 4.4 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via:
uv/0.11.29 {"installer":{"name":"uv","version":"0.11.29","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
8d0e2c4318c01b8d82001678e53a3365c7e138a8c9a4711e60868eba51e392e3
|
|
| MD5 |
251590102ba3604be7c83175be9e3998
|
|
| BLAKE2b-256 |
5fd5f44e65a2abfd756762a5f345bf3518d8362e41a8fba3e0d28a19cf7ef150
|
File details
Details for the file modern_di_faststream-3.0.0-py3-none-any.whl.
File metadata
- Download URL: modern_di_faststream-3.0.0-py3-none-any.whl
- Upload date:
- Size: 5.0 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via:
uv/0.11.29 {"installer":{"name":"uv","version":"0.11.29","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
f31eb156e467dd2df0efca58365e6b4f0333548ddbe473751e3758e68a43d989
|
|
| MD5 |
832afcae443022f59edc38c554abcd91
|
|
| BLAKE2b-256 |
580fb184d20dfc010aa30990dd10768fbff4373dfc185754641c943007b183e2
|
