modern-di-faststream

Usage example: examples/

Installation

uv add modern-di-faststream      # or: pip install modern-di-faststream

Usage

setup_di registers the root container and installs a broker middleware that builds a request container per message; 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])
setup_di(app, container)
container.validate()  # optional fail-fast; must come after setup_di registers its providers


@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 and registers startup/shutdown lifecycle hooks: on startup it reopens the container and adds the DI middleware to every broker of the app (including one added via app.add_broker after setup_di), after shutdown it closes the container
FromDI(dependency, *, use_cache=True, cast=False) — FastStream Depends that resolves a provider (or type) from the request container. Raises RuntimeError naming setup_di when a message reaches it without the middleware installed
fetch_di_container(app) — returns the root container from the app context
faststream_message_provider — ContextProvider for the current faststream.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.

Metadata

Release files for modern-di-faststream 3.0.2

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for modern-di-faststream 3.0.2
File	Size	Uploaded
modern_di_faststream-3.0.2.tar.gz	4.9 kB	Sep 15, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for modern-di-faststream 3.0.2
File	Interpreter	ABI	Platform	Reset
modern_di_faststream-3.0.2-py3-none-any.whl 5.4 kB Sep 15, 2026	Python 3	none	any	Details

Total release size: 10.2 kB

Release files / modern_di_faststream-3.0.2.tar.gz

Download URL	modern_di_faststream-3.0.2.tar.gz
Size	4.9 kB
Tags	Source
SHA-256 checksum How to use checksums	`ba25d1bb2a5beca217099ff78e45fa468332c747accef069c4b05b1986d7412e`
BLAKE2b-256 checksum How to use checksums	`09eaab5b7aa4bdfd4c4207da5f21f54a141500b41f1ad67ade38c3d9cb208b25`
Upload date	Sep 15, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.15 {"installer":{"name":"uv","version":"0.12.15","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}`

Release files / modern_di_faststream-3.0.2-py3-none-any.whl

Download URL	modern_di_faststream-3.0.2-py3-none-any.whl
Size	5.4 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`2ed882194f64fd6c8aaee2aeda70813c3e7893857a1b71e536bab830a0e721ac`
BLAKE2b-256 checksum How to use checksums	`3b912c43dae46c15247949095417864673e854652b0324b1dcffc19d5a837591`
Upload date	Sep 15, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.15 {"installer":{"name":"uv","version":"0.12.15","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}`