faststream

(★ 5,310)

FastStream은 이벤트 기반 애플리케이션을 구축하기 위한 비동기 Python 프레임워크입니다. 메시지 브로커 통합, 의존성 주입, 유효성 검사, 테스트 유틸리티, 그리고 AsyncAPI 문서 생성 기능을 단일 툴킷으로 결합해 줍니다.

파일 탐색기

ZIP 다운로드

- - 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
  - test_basic.py
  - test_confluent.py
  - test_msgspec.py
  - test_pydantic.py
- - __init__.py
  - test_aiokafka.py
  - test_basic.py
  - test_msgspec.py
  - test_pydantic.py
- - __init__.py
  - test_basic.py
  - test_msgspec.py
  - test_nats.py
  - test_pydantic.py
  - test_stream.py
- - __init__.py
  - test_aiopika.py
  - test_basic.py
  - test_msgspec.py
  - test_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
- - .meta.yml
  - navigation_template.txt
- - __init__.py
- - 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
- __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
  - _compat.py
  - application.py
  - basic_types.py
  - constants.py
  - middlewares.py
  - parser.py
  - producer.py
  - proto.py
  - types.py
- - __init__.py
  - annotations.py
  - app.py
  - handlers.py
  - params.py
  - request.py
  - response.py
  - types.py
  - websocket.py
- - __init__.py
  - annotations.py
  - message.py
  - parser.py
  - response.py
  - security.py
  - testing.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
  - exception.py
  - logging.py
- - __init__.py
  - annotations.py
  - message.py
  - parser.py
  - path.py
  - response.py
  - security.py
  - testing.py
  - utils.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
  - annotations.py
  - message.py
  - parser.py
  - response.py
  - security.py
  - testing.py
  - types.py
  - utils.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
- __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_app.py
  - test_lifespan.py
  - testcase.py
- - __init__.py
  - test_asgi.py
  - test_basics.py
  - test_fastapi_router.py
- - __init__.py
  - test_response.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
- - __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
- - __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
  - basic.py
- - __init__.py
  - basic.py
  - test_metrics.py
  - utils.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

# 설치 가이드

python

사전 준비물

설치 및 실행 절차

pip install 'faststream[kafka]'

FastStream 패키지와 Kafka 의존성 설치

python app.py

FastStream 애플리케이션 실행

핵심 명령어

pip install 'faststream[kafka]'

Kafka 브로커 지원을 포함하여 FastStream을 설치합니다.

pip install 'faststream[rabbit]'

RabbitMQ 브로커 지원을 포함하여 FastStream을 설치합니다.

사용하려는 메시지 브로커(Kafka, RabbitMQ 등)가 로컬 또는 원격에 미리 실행되어 있어야 합니다.

# CDN으로 사용하기

jsDelivr

jsDelivr는 공개 GitHub 리포지토리를 별도 설정 없이 CDN으로 즉시 서빙합니다. 버전과 파일을 고르면 웹페이지에 바로 붙일 수 있는 링크와 예시 코드가 만들어집니다.

버전

파일

링크

예시

명령어 용어집

이 문서에서 사용된 명령어를 모아봤습니다. 낯선 명령어가 있다면 펼쳐서 확인해보세요.

🔍

`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`

설명 보기 ▼

Python 패키지 관리자.
`install`와 같은 일부 하위 명령어는 별도의 사용 문서가 존재.
더 많은 정보: <https://pip.pypa.io/en/stable/cli/pip/>.

pip install {{package}}

패키지 설치 (더 많은 설치 예시는 `pip install`를 참고):

pip install --user {{package}}

시스템 전체 기본 위치 대신 사용자 디렉터리에 패키지 설치:

pip install {{[-U|--upgrade]}} {{package}}

패키지 업그레이드:

🔍

`pytest`

설명 보기 ▼

Python 테스트 실행.
더 많은 정보: <https://docs.pytest.org/en/latest/how-to/usage.html>.

pytest {{path/to/test_file1.py path/to/test_file2.py ...}}

특정 파일에서 테스트 실행:

pytest -k {{expression}}

특정 [k]eyword 표현식과 일치하는 테스트 실행:

pytest {{[-x|--exitfirst]}}

테스트가 실패하거나 오류가 발생하면 즉시 종료:

faststream

오너의 다른 레포

파일 탐색기

# 설치 가이드

설치 및 실행 절차

핵심 명령어

# CDN으로 사용하기

명령어 용어집

`pip install`

`pip`

`pytest`

Was this content helpful?

Recent Feedback

faststream

오너의 다른 레포

파일 탐색기

# 설치 가이드

설치 및 실행 절차

핵심 명령어

# CDN으로 사용하기

명령어 용어집

pip install

pip

pytest

Was this content helpful?

Recent Feedback

Download README

`pip install`

`pip`

`pytest`