faststream
FastStream is an asynchronous Python framework for building event-driven applications. It brings together message broker integration, dependency injection, validation, testing utilities, and AsyncAPI documentation generation in a single toolkit
File Explorer
- SKILL.md
- SKILL.md
- SKILL.md
- SKILL.md
- code-architecture
- dev-workflow
- documentation-writing
- testing-patterns
- bug_report.md
- config.yaml
- feature_request.md
- check-md-code-blocks.yaml
- codspeed_benchmarks.yaml
- docs_build.yaml
- docs_update-release-notes.yaml
- pr_automerge.yaml
- pr_autoupdate.yaml
- pr_codeql.yaml
- pr_dependency-review.yaml
- pr_labeler.yaml
- pr_tests.yaml
- publish_coverage.yaml
- relator.yaml
- release_pypi.yaml
- CODE_OF_CONDUCT.md
- CODEOWNERS
- dependabot.yml
- labeler.yml
- PULL_REQUEST_TEMPLATE.md
- SECURITY.md
- zizmor.yml
- __init__.py
- msgspec.py
- pydantic.py
- __init__.py
- test_basic.py
- test_confluent.py
- test_msgspec.py
- test_pydantic.py
- __init__.py
- msgspec.py
- pydantic.py
- __init__.py
- test_aiokafka.py
- test_basic.py
- test_msgspec.py
- test_pydantic.py
- __init__.py
- msgspec.py
- pydantic.py
- __init__.py
- test_basic.py
- test_msgspec.py
- test_nats.py
- test_pydantic.py
- test_stream.py
- __init__.py
- msgspec.py
- pydantic.py
- __init__.py
- test_aiopika.py
- test_basic.py
- test_msgspec.py
- test_pydantic.py
- __init__.py
- msgspec.py
- pydantic.py
- __init__.py
- test_basic.py
- test_msgspec.py
- test_pydantic.py
- test_redis.py
- __init__.py
- bench.py
- benches.csv
- README.md
- people.yml
- a-alphabet-round-icon.png
- AsyncAPI-basic-html-full.png
- AsyncAPI-basic-html-short.png
- AsyncAPI-custom-broker.png
- AsyncAPI-custom-handler.png
- AsyncAPI-custom-info.png
- AsyncAPI-hidden-servers.png
- AsyncAPI-payload-info.png
- distributed-trace.png
- grafana-dashboard.png
- I.svg
- import-dashboard.png
- letter-d.png
- letter-e.png
- logfire-trace.png
- logo.svg
- middlewares-flow.svg
- nats-twitter-logo.jpeg
- p-alphabet-round-icon.png
- prototype.svg
- reddit-logo.png
- robot-hero-2.svg
- robot-hero.svg
- Robot_chilling_transparent.svg
- Robot_wins_first_prize_transparent.svg
- sentry-trace.png
- shield.json
- simple-trace.png
- streamline.svg
- twitter-logo.svg
- write.svg
- Y_Combinator_Logo.png
- .meta.yml
- index.md
- batch_publisher.md
- index.md
- using_a_key.md
- batch_subscriber.md
- index.md
- ack.md
- additional-configuration.md
- index.md
- message.md
- security.md
- custom.md
- export.md
- hosting.md
- index.md
- .meta.yml
- CONTRIBUTING.md
- docs.md
- class.md
- global.md
- index.md
- sub.md
- testing.md
- yield.md
- index.md
- index.md
- index.md
- context.md
- hooks.md
- index.md
- test.md
- exception.md
- index.md
- baggage.md
- index.md
- sentry.md
- tracing.md
- healthcheks.md
- logging.md
- prometheus.md
- broker.md
- decorator.md
- direct.md
- index.md
- object.md
- test.md
- index.md
- decoder.md
- examples.md
- index.md
- parser.md
- annotation.md
- dynamic.md
- filtering.md
- index.md
- msgspec.md
- pydantic.md
- test.md
- index.md
- acknowledgement.md
- asgi.md
- cli.md
- context.md
- index.md
- multiple_brokers.md
- index.md
- index.md
- rpc.md
- dynaconf.md
- in-progress.md
- index.md
- index.md
- index.md
- batch_publisher.md
- index.md
- using_a_key.md
- batch_subscriber.md
- index.md
- ack.md
- index.md
- kafka.md
- message.md
- security.md
- ack.md
- index.md
- message.md
- publishing.md
- rpc.md
- security.md
- shared.md
- versions.md
- direct.md
- pattern.md
- ack.md
- index.md
- key-value.md
- object.md
- pull.md
- scheduling.md
- index.md
- index.md
- message.md
- rpc.md
- direct.md
- fanout.md
- headers.md
- index.md
- stream.md
- topic.md
- ack.md
- declare.md
- index.md
- message.md
- publishing.md
- rpc.md
- security.md
- batch.md
- index.md
- publishing.md
- subscription.md
- index.md
- publishing.md
- subscription.md
- ack.md
- batch.md
- claiming.md
- groups.md
- index.md
- publishing.md
- subscription.md
- testing.md
- cluster.md
- index.md
- message.md
- message_format.md
- pipeline.md
- rpc.md
- security.md
- sentinel.md
- faststream-people.md
- faststream.md
- index.md
- llms.txt
- public_api
- release.md
- scheduling.md
- extra.js
- gurubase-widget.js
- theme-switch.js
- extra.css
- .meta.yml
- navigation_template.txt
- __init__.py
- errors.py
- __init__.py
- app.py
- __init__.py
- basic.py
- __init__.py
- app.py
- __init__.py
- app.py
- app.py
- __init__.py
- app.py
- __init__.py
- app.py
- __init__.py
- app.py
- example.py
- __init__.py
- example.py
- __init__.py
- basic.py
- custom_config.py
- plaintext.py
- sasl_gssapi.py
- sasl_oauthbearer.py
- sasl_scram256.py
- sasl_scram512.py
- __init__.py
- __init__.py
- auth_app.py
- custom_app.py
- healthcheck_app.py
- logging_app.py
- __init__.py
- basic.py
- custom_broker.py
- custom_handler.py
- custom_info.py
- payload_info.py
- __init__.py
- serve.py
- context.py
- extra_options.py
- worker_id.py
- context.py
- extra_options.py
- worker_id.py
- __init__.py
- context.py
- extra_options.py
- worker_id.py
- context.py
- extra_options.py
- worker_id.py
- context.py
- extra_options.py
- worker_id.py
- context.py
- extra_options.py
- worker_id.py
- __init__.py
- __init__.py
- settings_base_1.py
- settings_base_2.py
- settings_env.py
- usage.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- annotated.py
- cast.py
- custom_global_context.py
- custom_local_context.py
- default_arguments.py
- existed_context.py
- fields_access.py
- initial.py
- __init__.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- depends.py
- nested_depends.py
- __init__.py
- async_.py
- sync.py
- __init__.py
- basic_kafka.py
- class_kafka.py
- global_broker_kafka.py
- global_kafka.py
- sub_dep_kafka.py
- yield_kafka.py
- __init__.py
- base_confluent.py
- base_kafka.py
- base_mqtt.py
- base_nats.py
- base_rabbit.py
- base_redis.py
- __init__.py
- basic.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- basic.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- basic.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- basic.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- basic.py
- ml.py
- ml_context.py
- testing.py
- __init__.py
- multiple.py
- __init__.py
- confluent_base_run.py
- kafka_base_run.py
- mqtt_base_run.py
- nats_base_run.py
- rabbit_base_run.py
- redis_base_run.py
- __init__.py
- __init__.py
- add_broker.py
- app.py
- same_type_app.py
- same_type_testing.py
- testing.py
- __init__.py
- confluent_telemetry.py
- kafka_telemetry.py
- mqtt_telemetry.py
- nats_telemetry.py
- rabbit_telemetry.py
- redis_telemetry.py
- __init__.py
- confluent.py
- confluent_asgi.py
- kafka.py
- kafka_asgi.py
- kafka_custom_metric.py
- mqtt.py
- mqtt_asgi.py
- nats.py
- nats_asgi.py
- rabbit.py
- rabbit_asgi.py
- redis.py
- redis_asgi.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- broker.py
- broker_context.py
- decorator.py
- direct.py
- direct_testing.py
- object.py
- object_testing.py
- __init__.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- delay_equal.py
- router.py
- router_delay.py
- __init__.py
- __init__.py
- avro.py
- msgpack_ex.py
- parser_confluent.py
- parser_kafka.py
- parser_mqtt.py
- parser_nats.py
- parser_rabbit.py
- parser_redis.py
- person.avsc
- protobuf.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- annotation.py
- dynamic.py
- dynamic_iter.py
- filter.py
- full_testing.py
- msgspec_fields.py
- msgspec_struct.py
- pydantic_annotated_fields.py
- pydantic_fields.py
- pydantic_model.py
- real_testing.py
- testing.py
- __init__.py
- __init__.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- basic.py
- pydantic.py
- test.py
- __init__.py
- app_description.txt
- dependencies.py
- dependencies_annotated.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- base.py
- depends.py
- router.py
- send.py
- startup.py
- test.py
- __init__.py
- __init__.py
- aiohttp.py
- blacksheep.py
- falcon.py
- fastapi.py
- litestar.py
- quart.py
- sanic.py
- tornado.py
- __init__.py
- aiogram.py
- __init__.py
- __init__.py
- errors.py
- __init__.py
- basic.py
- __init__.py
- app.py
- __init__.py
- app.py
- app.py
- __init__.py
- app.py
- __init__.py
- app.py
- __init__.py
- app.py
- example.py
- __init__.py
- example.py
- __init__.py
- basic.py
- plaintext.py
- sasl_gssapi.py
- sasl_oauthbearer.py
- sasl_scram256.py
- sasl_scram512.py
- __init__.py
- __init__.py
- manual.py
- __init__.py
- fields.py
- literal_braces.py
- path.py
- wildcard.py
- __init__.py
- publish.py
- publisher_decorator.py
- publisher_object.py
- __init__.py
- mqtt311.py
- mqtt5.py
- mqtt_response.py
- __init__.py
- plaintext.py
- __init__.py
- basic.py
- __init__.py
- basic.py
- __init__.py
- errors.py
- __init__.py
- key_value.py
- main.py
- object.py
- pull_sub.py
- pull_sub_batch_example.py
- __init__.py
- direct.py
- pattern.py
- __init__.py
- errors.py
- __init__.py
- basic.py
- external.py
- plaintext.py
- __init__.py
- direct.py
- fanout.py
- header.py
- index.py
- stream.py
- topic.py
- __init__.py
- bind.py
- declare.py
- __init__.py
- list_pub.py
- list_sub.py
- sub_batch.py
- __init__.py
- pipeline.py
- __init__.py
- channel_sub.py
- channel_sub_pattern.py
- pattern_data.py
- publisher_decorator.py
- publisher_object.py
- raw_publish.py
- __init__.py
- app.py
- __init__.py
- basic.py
- plaintext.py
- __init__.py
- ack_errors.py
- batch_sub.py
- claiming_basic.py
- claiming_manual_ack.py
- group.py
- pel_multiple_groups.py
- pel_no_ack.py
- pel_pending.py
- pel_reprocessing.py
- pel_testing.py
- pub.py
- sub.py
- __init__.py
- __init__.py
- scaling.md
- env-context.md
- extra-options.md
- no_ack.md
- simple-apps.md
- worker-id.md
- annotated.md
- attrs.md
- headers.md
- app.md
- taskiq_broker.md
- docker-compose.yaml
- 404.html
- home.html
- main.html
- redirect.html
- __init__.py
- create_api_docs.py
- docs.py
- expand_markdown.py
- mkdocs.yml
- README.md
- update_releases.py
- __init__.py
- app.py
- testing.py
- __init__.py
- structlogs.py
- __init__.py
- ack_after_process.py
- batch_consume.py
- batch_publish_1.py
- batch_publish_2.py
- batch_publish_3.py
- testing.py
- __init__.py
- e01_basic.py
- e02_basic_rpc.py
- e03_publisher.py
- e04_js_basic.py
- e05_basic_and_js.py
- e06_key_value.py
- e07_object_storage.py
- e08_wildcards.py
- e09_pull_sub.py
- __init__.py
- direct.py
- fanout.py
- header.py
- stream.py
- topic.py
- __init__.py
- channel_sub.py
- channel_sub_pattern.py
- list_sub.py
- list_sub_batch.py
- rpc.py
- stream_sub.py
- stream_sub_batch.py
- __init__.py
- basic_consume.py
- basic_publish.py
- delay_registration.py
- __init__.py
- avro.py
- person.avsc
- requirements.txt
- __init__.py
- pack.py
- requirements.txt
- __init__.py
- message.proto
- protobuf.py
- requirements.txt
- __init__.py
- __init__.py
- e01_basic_consume.py
- e02_1_basic_publisher.py
- e02_2_basic_publisher.py
- e02_3_basic_publisher.py
- e03_multiple_pubsub.py
- e04_msg_filter.py
- e05_rpc_request.py
- e06_manual_ack.py
- e07_ack_immediately.py
- e08_testing.py
- e09_testing_mocks.py
- e10_middlewares.py
- e11_settings.py
- __init__.py
- broker.py
- pub_base.py
- registrator.py
- router.py
- __init__.py
- asgi_multiprocess.py
- basereload.py
- multiprocess.py
- utils.py
- watchfiles.py
- __init__.py
- errors.py
- imports.py
- logs.py
- parser.py
- __init__.py
- docs.py
- dto.py
- main.py
- options.py
- __init__.py
- broker.py
- endpoint.py
- specification.py
- __init__.py
- composition.py
- context_type.py
- repository.py
- resolve.py
- __init__.py
- config.py
- __init__.py
- fake.py
- proto.py
- specification.py
- usecase.py
- __init__.py
- call_item.py
- mixins.py
- specification.py
- supervisor.py
- usecase.py
- utils.py
- __init__.py
- call_wrapper.py
- usecase.py
- utils.py
- __init__.py
- _compat.py
- config.py
- context.py
- get_dependant.py
- route.py
- router.py
- __init__.py
- formatter.py
- logger_proxy.py
- logging.py
- params_storage.py
- state.py
- __init__.py
- app.py
- ast.py
- broker.py
- __init__.py
- data.py
- functions.py
- nuid.py
- path.py
- __init__.py
- _compat.py
- application.py
- basic_types.py
- constants.py
- middlewares.py
- parser.py
- producer.py
- proto.py
- types.py
- __init__.py
- docs.py
- route.py
- try_it_out.py
- __init__.py
- ping.py
- __init__.py
- annotations.py
- app.py
- handlers.py
- params.py
- request.py
- response.py
- types.py
- websocket.py
- __init__.py
- broker.py
- logging.py
- registrator.py
- router.py
- __init__.py
- broker.py
- __init__.py
- fastapi.py
- __init__.py
- admin.py
- client.py
- config.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- producer.py
- specification.py
- state.py
- usecase.py
- __init__.py
- partition.py
- __init__.py
- config.py
- factory.py
- specification.py
- usecase.py
- __init__.py
- annotations.py
- message.py
- parser.py
- response.py
- security.py
- testing.py
- __init__.py
- broker.py
- logging.py
- registrator.py
- router.py
- __init__.py
- broker.py
- __init__.py
- fastapi.py
- __init__.py
- rebalance_listener.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- producer.py
- specification.py
- state.py
- usecase.py
- __init__.py
- params.py
- __init__.py
- config.py
- factory.py
- specification.py
- usecase.py
- __init__.py
- annotations.py
- exceptions.py
- message.py
- parser.py
- response.py
- security.py
- testing.py
- __init__.py
- message.py
- source_type.py
- utils.py
- __init__.py
- config.py
- middleware.py
- __init__.py
- exception.py
- logging.py
- __init__.py
- broker.py
- config.py
- logging.py
- registrator.py
- router.py
- __init__.py
- fastapi.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- producer.py
- specification.py
- usecase.py
- __init__.py
- config.py
- factory.py
- specification.py
- usecase.py
- __init__.py
- annotations.py
- message.py
- parser.py
- path.py
- response.py
- security.py
- testing.py
- utils.py
- __init__.py
- broker.py
- logging.py
- registrator.py
- router.py
- state.py
- __init__.py
- broker.py
- __init__.py
- fastapi.py
- __init__.py
- bucket_declarer.py
- obj_storage_declarer.py
- state.py
- stream_builder.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- producer.py
- specification.py
- usecase.py
- __init__.py
- js_stream.py
- kv_watch.py
- obj_watch.py
- pull_sub.py
- schedule.py
- __init__.py
- basic.py
- core_subscriber.py
- key_value_subscriber.py
- object_storage_subscriber.py
- stream_basic.py
- stream_pull_subscriber.py
- stream_push_subscriber.py
- __init__.py
- adapters.py
- config.py
- factory.py
- specification.py
- state.py
- __init__.py
- annotations.py
- message.py
- parser.py
- response.py
- security.py
- testing.py
- __init__.py
- annotations.py
- baggage.py
- consts.py
- middleware.py
- provider.py
- __init__.py
- no_cast.py
- params.py
- __init__.py
- consts.py
- container.py
- manager.py
- middleware.py
- provider.py
- types.py
- __init__.py
- broker.py
- logging.py
- registrator.py
- router.py
- __init__.py
- base.py
- broker.py
- __init__.py
- fastapi.py
- __init__.py
- channel_manager.py
- declarer.py
- state.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- options.py
- producer.py
- specification.py
- usecase.py
- __init__.py
- channel.py
- constants.py
- exchange.py
- queue.py
- __init__.py
- config.py
- factory.py
- specification.py
- usecase.py
- __init__.py
- annotations.py
- message.py
- parser.py
- response.py
- security.py
- testing.py
- types.py
- utils.py
- __init__.py
- broker.py
- cluster_broker.py
- logging.py
- registrator.py
- router.py
- sentinel_broker.py
- __init__.py
- broker.py
- state.py
- __init__.py
- fastapi.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- binary.py
- message.py
- parsers.py
- __init__.py
- middleware.py
- provider.py
- __init__.py
- config.py
- factory.py
- fake.py
- producer.py
- specification.py
- usecase.py
- __init__.py
- list_sub.py
- proto.py
- pub_sub.py
- stream_sub.py
- types.py
- __init__.py
- basic.py
- channel_subscriber.py
- list_subscriber.py
- stream_subscriber.py
- __init__.py
- config.py
- factory.py
- specification.py
- __init__.py
- _compat.py
- annotations.py
- exceptions.py
- message.py
- response.py
- security.py
- testing.py
- __init__.py
- publish_type.py
- response.py
- utils.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- __init__.py
- channels.py
- components.py
- contact.py
- docs.py
- info.py
- license.py
- message.py
- operations.py
- schema.py
- servers.py
- tag.py
- utils.py
- __init__.py
- generate.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- channel.py
- operation.py
- __init__.py
- http.py
- kafka.py
- mqtt.py
- nats.py
- redis.py
- sqs.py
- __init__.py
- channels.py
- components.py
- contact.py
- docs.py
- info.py
- license.py
- message.py
- operations.py
- schema.py
- servers.py
- tag.py
- utils.py
- __init__.py
- generate.py
- __init__.py
- factory.py
- message.py
- site.py
- utils.py
- __init__.py
- generator.py
- info.py
- schema.py
- specification.py
- __init__.py
- amqp.py
- http.py
- kafka.py
- main.py
- mqtt.py
- nats.py
- redis.py
- sqs.py
- __init__.py
- contact.py
- external_docs.py
- license.py
- tag.py
- __init__.py
- model.py
- __init__.py
- model.py
- __init__.py
- broker.py
- publisher.py
- subscriber.py
- __init__.py
- __about__.py
- __init__.py
- __main__.py
- annotations.py
- app.py
- cli.py
- context.py
- exceptions.py
- py.typed
- security.py
- types.py
- __init__.py
- test_delayed_broker.py
- __init__.py
- test_asgi.py
- __init__.py
- test_asgi.py
- __init__.py
- test_try_it_out.py
- __init__.py
- test_asgi.py
- __init__.py
- test_asgi.py
- __init__.py
- test_asgi.py
- __init__.py
- test_app.py
- test_lifespan.py
- testcase.py
- __init__.py
- test_contact.py
- test_external_docs.py
- test_license.py
- test_tag.py
- __init__.py
- arguments.py
- basic.py
- fastapi.py
- naming.py
- publisher.py
- router.py
- __init__.py
- arguments.py
- basic.py
- fastapi.py
- naming.py
- publisher.py
- router.py
- __init__.py
- basic.py
- __init__.py
- base.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- base.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- __init__.py
- test_app.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- __init__.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_kv_schema.py
- test_naming.py
- test_obj_schema.py
- test_publisher.py
- test_router.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_kv_schema.py
- test_naming.py
- test_obj_schema.py
- test_publisher.py
- test_router.py
- __init__.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- test_arguments.py
- test_connection.py
- test_fastapi.py
- test_naming.py
- test_publisher.py
- test_router.py
- test_security.py
- __init__.py
- __init__.py
- test_asgi.py
- test_basics.py
- test_fastapi_router.py
- __init__.py
- fastapi.py
- __init__.py
- basic.py
- codec.py
- connection.py
- consume.py
- fastapi.py
- include_router.py
- middlewares.py
- parser.py
- publish.py
- publish_command.py
- requests.py
- router.py
- testclient.py
- __init__.py
- test_fastapi.py
- __init__.py
- basic.py
- conftest.py
- settings.py
- test_ack_policy.py
- test_batch_body.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_fastapi.py
- test_include_router.py
- test_lazy_logger_proxy.py
- test_logger.py
- test_middlewares.py
- test_misconfigure.py
- test_parser.py
- test_publish.py
- test_publish_command.py
- test_requests.py
- test_router.py
- test_security.py
- test_test_client.py
- test_test_reentrancy.py
- __init__.py
- test_fastapi.py
- __init__.py
- basic.py
- conftest.py
- settings.py
- test_ack_policy.py
- test_batch_body.py
- test_cancellation.py
- test_client_rack.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_consumer_only.py
- test_fastapi.py
- test_group_instance_id.py
- test_include_router.py
- test_middlewares.py
- test_misconfigure.py
- test_parser.py
- test_publish.py
- test_publish_command.py
- test_requests.py
- test_router.py
- test_test_client.py
- test_test_reentrancy.py
- __init__.py
- basic.py
- conftest.py
- settings.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_fastapi.py
- test_middlewares.py
- test_path.py
- test_publish.py
- test_requests.py
- test_security.py
- test_shared_topic.py
- test_testclient.py
- test_url.py
- test_v311_restrictions.py
- __init__.py
- test_fastapi.py
- __init__.py
- basic.py
- conftest.py
- settings.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_fastapi.py
- test_include_router.py
- test_kv_declarer_cache.py
- test_middlewares.py
- test_misconfiguration.py
- test_new_inbox.py
- test_os_declarer_cache.py
- test_overlapping_subjects.py
- test_parser.py
- test_publish.py
- test_requests.py
- test_router.py
- test_test_client.py
- test_test_reentrancy.py
- __init__.py
- test_call_manual.py
- test_depends.py
- __init__.py
- test_fastapi.py
- __init__.py
- test_channels.py
- test_declare.py
- test_init.py
- test_nested_exchange.py
- __init__.py
- basic.py
- conftest.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_fastapi.py
- test_include_router.py
- test_middlewares.py
- test_misconfigure.py
- test_parser.py
- test_publish.py
- test_requests.py
- test_router.py
- test_schemas.py
- test_security.py
- test_test_client.py
- test_test_reentrancy.py
- test_url_builder.py
- __init__.py
- conftest.py
- settings.py
- test_cluster.py
- test_cluster_codec.py
- test_cluster_connect.py
- test_cluster_consume.py
- test_cluster_include_router.py
- test_cluster_middlewares.py
- test_cluster_more_unit.py
- test_cluster_publish.py
- test_cluster_pubsub_more.py
- test_cluster_requests.py
- test_cluster_test_client.py
- __init__.py
- test_fastapi.py
- __init__.py
- test_sentinel.py
- __init__.py
- basic.py
- conftest.py
- settings.py
- test_autoclaim.py
- test_codec.py
- test_config.py
- test_connect.py
- test_consume.py
- test_fastapi.py
- test_include_router.py
- test_middlewares.py
- test_misconfigure.py
- test_parser.py
- test_publish.py
- test_publish_command.py
- test_requests.py
- test_router.py
- test_schemas.py
- test_security.py
- test_stream_group_pel.py
- test_test_client.py
- test_test_reentrancy.py
- __init__.py
- conftest.py
- test_supervisor.py
- __init__.py
- test_response.py
- __init__.py
- test_app.py
- test_logs.py
- __init__.py
- test_base_reloader.py
- test_multiprocess.py
- test_watchfiles.py
- __init__.py
- test_errors.py
- test_imports.py
- test_parser.py
- __init__.py
- conftest.py
- interfaces.py
- test_asyncapi_docs.py
- test_logs.py
- test_loop.py
- test_publish.py
- test_run.py
- test_run_asgi.py
- test_version.py
- test_worker_id_extra_option.py
- __init__.py
- test_errors.py
- __init__.py
- test_app.py
- __init__.py
- test_basic.py
- test_cmd_run.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- test_issues.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_publisher_object.py
- __init__.py
- test_raw_publish.py
- __init__.py
- test_security.py
- __init__.py
- test_auth_app.py
- test_custom_app.py
- test_healthcheck_app.py
- test_logging_app.py
- __init__.py
- test_basic.py
- test_broker.py
- test_handler.py
- test_info.py
- test_payload.py
- __init__.py
- __init__.py
- test_confluent_context.py
- __init__.py
- test_kafka_context.py
- __init__.py
- test_mqtt_context.py
- __init__.py
- test_nats_context.py
- __init__.py
- test_rabbit_context.py
- __init__.py
- test_redis_context.py
- __init__.py
- __init__.py
- test_settings_base_1.py
- test_settings_base_2.py
- test_settings_env.py
- test_usage.py
- __init__.py
- test_annotated.py
- test_cast.py
- test_custom_global.py
- test_custom_local.py
- test_default_arguments.py
- test_existed_context.py
- test_fields_access.py
- test_initial.py
- __init__.py
- test_base.py
- test_depends.py
- test_nested_depends.py
- __init__.py
- test_basic.py
- test_class.py
- test_global.py
- test_global_broker.py
- test_sub_dep.py
- test_yield.py
- __init__.py
- test_basic.py
- __init__.py
- test_ml.py
- test_ml_context.py
- test_multi.py
- test_testing.py
- __init__.py
- test_app.py
- __init__.py
- test_kafka_custom_metric.py
- __init__.py
- test_broker.py
- test_broker_context.py
- test_decorator.py
- test_direct.py
- test_object.py
- __init__.py
- test_base.py
- test_delay.py
- test_delay_equal.py
- __init__.py
- test_parser.py
- __init__.py
- test_annotated.py
- test_filter.py
- test_full_testing.py
- test_pydantic.py
- test_real.py
- test_testing.py
- __init__.py
- __init__.py
- test_basic.py
- test_dependencies.py
- test_pydantic.py
- __init__.py
- test_base.py
- test_depends.py
- test_routers.py
- test_send.py
- test_startup.py
- test_test.py
- __init__.py
- test_fastapi.py
- __init__.py
- __init__.py
- test_errors.py
- __init__.py
- test_basic.py
- test_cmd_run.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- test_issues.py
- __init__.py
- test_app.py
- __init__.py
- test_app.py
- __init__.py
- test_publisher_object.py
- __init__.py
- test_raw_publish.py
- __init__.py
- test_security.py
- __init__.py
- test_manual.py
- __init__.py
- test_message.py
- __init__.py
- test_publish.py
- __init__.py
- test_rpc.py
- __init__.py
- test_security.py
- __init__.py
- test_shared.py
- __init__.py
- test_basic.py
- __init__.py
- test_errors.py
- __init__.py
- test_kv.py
- test_main.py
- test_object.py
- test_pull_sub.py
- test_pull_sub_batch_example.py
- __init__.py
- test_direct.py
- test_pattern.py
- __init__.py
- test_errors.py
- __init__.py
- test_direct.py
- test_fanout.py
- test_header.py
- test_index.py
- test_stream.py
- test_topic.py
- __init__.py
- test_bind.py
- test_declare.py
- test_security.py
- __init__.py
- test_list_pub.py
- test_list_sub.py
- test_sub_batch.py
- __init__.py
- test_channel_sub.py
- test_channel_sub_pattern.py
- test_pattern_data.py
- test_publisher_decorator.py
- test_publisher_object.py
- test_raw_publish.py
- __init__.py
- test_ack_errors.py
- test_batch_sub.py
- test_claiming.py
- test_group.py
- test_pel.py
- test_pub.py
- test_sub.py
- __init__.py
- test_pipeline.py
- test_rpc.py
- test_security.py
- __init__.py
- __init__.py
- test_app.py
- __init__.py
- test_ack.py
- test_batch_consume.py
- test_batch_publish_1.py
- test_batch_publish_2.py
- test_batch_publish_3.py
- test_example.py
- __init__.py
- test_e01_basic.py
- test_e02_basic_rpc.py
- test_e03_publisher.py
- test_e04_js_basic.py
- test_e05_basic_and_js.py
- test_e06_key_value.py
- test_e07_object_storage.py
- test_e08_wildcards.py
- test_e09_pull_sub.py
- __init__.py
- test_direct.py
- test_fanout.py
- test_header.py
- test_stream.py
- test_topic.py
- __init__.py
- test_channel_sub.py
- test_channel_sub_pattern.py
- test_list_sub.py
- test_list_sub_batch.py
- test_rpc.py
- test_stream_batch_sub.py
- test_stream_sub.py
- __init__.py
- test_basic_consume.py
- test_basic_publish.py
- test_delay_registration.py
- __init__.py
- test_e01_basic_consume.py
- test_e02_1_basic_publisher.py
- test_e02_2_basic_publisher.py
- test_e02_3_basic_publisher.py
- test_e03_multiple_pubsub.py
- test_e04_msg_filter.py
- test_e05_rpc_request.py
- test_e06_manual_ack.py
- test_e07_ack_immediately.py
- test_e08_testing.py
- test_e09_testing_mocks.py
- test_e10_middlewares.py
- test_e11_settings.py
- __init__.py
- test_get_dependant.py
- __init__.py
- test_serialization.py
- __init__.py
- __init__.py
- test_formatter.py
- test_logging.py
- __init__.py
- test_message.py
- test_utils.py
- __init__.py
- confluent.py
- kafka.py
- mqtt.py
- nats.py
- rabbit.py
- redis.py
- __init__.py
- test_confluent.py
- __init__.py
- test_kafka.py
- __init__.py
- test_mqtt.py
- __init__.py
- test_nats.py
- __init__.py
- test_rabbit.py
- __init__.py
- test_redis.py
- __init__.py
- basic.py
- __init__.py
- basic.py
- test_confluent.py
- test_provider.py
- __init__.py
- basic.py
- test_kafka.py
- test_provider.py
- __init__.py
- basic.py
- conftest.py
- test_mqtt.py
- __init__.py
- basic.py
- test_nats.py
- test_provider.py
- __init__.py
- basic.py
- test_provider.py
- test_rabbit.py
- __init__.py
- basic.py
- test_provider.py
- test_redis.py
- __init__.py
- basic.py
- test_metrics.py
- utils.py
- __init__.py
- test_alias.py
- test_composition.py
- test_depends.py
- test_headers.py
- test_main.py
- test_path.py
- __init__.py
- test_base.py
- test_model.py
- __init__.py
- test_ast.py
- test_functions.py
- test_handler_call_wrapper.py
- test_handler_lock.py
- test_no_cast.py
- __init__.py
- conftest.py
- marks.py
- mocks.py
- tools.py
- .dockerignore
- .gitignore
- .pre-commit-config.yaml
- CITATION.cff
- CONTRIBUTING.md
- docker-compose.yaml
- Dockerfile
- justfile
- LICENSE
- pyproject.toml
- README.md
- ruff.toml
- uv.lock
# Installation Guide
pythonPrerequisites
Setup Steps
pip install 'faststream[kafka]'
Install FastStream package with Kafka dependencies
python app.py
Run the FastStream application
Key Commands
pip install 'faststream[kafka]'
Install FastStream with Kafka broker support.
pip install 'faststream[rabbit]'
Install FastStream with RabbitMQ broker support.
The message broker you intend to use must be running locally or remotely.
# Use via CDN
jsDelivrjsDelivr serves any public GitHub repository as a CDN with zero setup. Pick a version and a file to get a ready-to-paste link and snippet.
Link
Example
Command Glossary
Commands referenced in this DOCs, explained below.
pip install
View Details ▼
pip install
Install Python packages.
pip install {{package1 package2 ...}}
Install one or more packages:
pip install {{package1 package2 ...}} {{[-U|--upgrade]}}
Upgrade all specified packages to the latest version, installing any that are not already present:
pip install {{package}}=={{version}}
Install a specific version of a package:
pip
View Details ▼
pip
Python package manager.
Some subcommands such as `install` have their own usage documentation.
pip install {{package}}
Install a package (see `pip install` for more install examples):
pip install --user {{package}}
Install a package to the user's directory instead of the system-wide default location:
pip install {{[-U|--upgrade]}} {{package}}
Upgrade a package:
pytest
View Details ▼
pytest
Run Python tests.
pytest {{path/to/test_file1.py path/to/test_file2.py ...}}
Run tests from specific files:
pytest -k {{expression}}
Run tests with names matching a specific [k]eyword expression:
pytest {{[-x|--exitfirst]}}
Exit as soon as a test fails or encounters an error:
// repository documentation
Was this content helpful?
(0 ratings)