faststream

FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.

APACHE-2.0 License

Downloads
160.6K
Stars
1.8K
Committers
15
View Code on GitHub Visit Website View on X
Ecosystems: Python, Redis

Bot releases are hidden (Show)

faststream - v0.1.6

Published by davorrunje about 1 year ago

What's Changed

Full Changelog: https://github.com/airtai/faststream/compare/0.1.5...0.1.6

faststream - v0.1.5

Published by davorrunje about 1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/airtai/faststream/compare/0.1.4...0.1.5

faststream - v0.1.4

Published by davorrunje about 1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/airtai/faststream/compare/0.1.3...0.1.4

faststream - v0.1.3

Published by davorrunje about 1 year ago

What's Changed

Full Changelog: https://github.com/airtai/faststream/compare/0.1.1...0.1.3

faststream - v0.1.1

Published by davorrunje about 1 year ago

What's Changed

Full Changelog: https://github.com/airtai/faststream/commits/0.1.1

faststream - v0.1.1rc0

Published by Sternakt about 1 year ago

Bugs Squashed

  • Fix documentation image not showing in the PyPi release
faststream - v0.1.0

Published by Sternakt about 1 year ago

Initial release

faststream - v0.8.0

Published by Sternakt over 1 year ago

New Features

  • Add support for Pydantic v2 (#408), thanks to @kumaranvpl

    • FastKafka now uses Pydantic v2 for serialization/deserialization of messages

  • Enable nbdev_test on windows and run CI tests on windows (#356), thanks to @kumaranvpl

Bugs Squashed

  • Fix ´fastkafka testing install deps´ failing (#385), thanks to @Sternakt

  • Create asyncapi docs directory only while building asyncapi docs (#368), thanks to @kumaranvpl

  • Add retries to producer in case of raised KafkaTimeoutError exception (#423), thanks to @Sternakt

faststream - v0.7.1

Published by Sternakt over 1 year ago

Bugs Squashed

  • Limit pydantic version to <2.0 (#427)

  • Fix Kafka broker version installation issues (#427)

  • Fix ApacheKafkaBroker startup issues (#427)

faststream - v0.7.0

Published by Sternakt over 1 year ago

New Features

  • Optional description argument to consumes and produces decorator implemented (#338), thanks to @Sternakt

    • Consumes and produces decorators now have optional description argument that is used instead of function docstring in async doc generation when specified

  • FastKafka Windows OS support enabled (#326), thanks to @kumaranvpl

    • FastKafka can now run on Windows

  • FastKafka and FastAPI integration implemented (#304), thanks to @kumaranvpl

    • FastKafka can now be run alongside FastAPI

  • Batch consuming option to consumers implemented (#298), thanks to @Sternakt

    • Consumers can consume events in batches by specifying msg type of consuming function as List[YourMsgType]

  • Removed support for synchronous produce functions (#295), thanks to @kumaranvpl

  • Added default broker values and update docs (#292), thanks to @Sternakt

Bugs Squashed

  • Fix index.ipynb to be runnable in colab (#342)

  • Use cli option root_path docs generate and serve CLI commands (#341), thanks to @kumaranvpl

  • Fix incorrect asyncapi docs path on fastkafka docs serve command (#335), thanks to @Sternakt

    • Serve docs now takes app root_path argument into consideration when specified in app

  • Fix typo (supress_timestamps->suppress_timestamps) and remove fix for enabling timestamps (#315)

  • Fix logs printing timestamps (#308)

  • Fix topics with dots causing failure of tester instantiation (#306), thanks to @Sternakt

    • Specified topics can now have "." in their names
faststream - v0.6.1

Published by Sternakt over 1 year ago

Bugs Squashed

  • Fixed topics with dots causing failure of tester instantiation (#305), thanks to @Sternakt
faststream - v0.6.0

Published by davorrunje over 1 year ago

New Features

  • Timestamps added to CLI commands (#283), thanks to @davorrunje

  • Added option to process messages concurrently (#278), thanks to @Sternakt

    • A new executor option is added that supports either sequential processing for tasks with small latencies or concurrent processing for tasks with larger latencies.

  • Add consumes and produces functions to app (#274), thanks to @Sternakt

  • Add batching for producers (#273), thanks to @Sternakt

  • Fix broken links in guides (#272), thanks to @harishmohanraj

  • Generate the docusaurus sidebar dynamically by parsing summary.md (#270), thanks to @harishmohanraj

  • Metadata passed to consumer (#269), thanks to @Sternakt

  • Contribution with instructions how to build and test added (#255), thanks to @Sternakt

  • Export encoders, decoders from fastkafka.encoder (#246), thanks to @kumaranvpl

  • Create a Github action file to automatically index the website and commit it to the FastKafkachat repository. (#239)

  • UI Improvement: Post screenshots with links to the actual messages in testimonials section (#228)

Bugs Squashed

  • Batch testing fix (#280), thanks to @Sternakt

  • Tester breaks when using Batching or KafkaEvent producers (#279)

  • Consumer loop callbacks are not executing in parallel (#276)

faststream - v0.5.0

Published by davorrunje over 1 year ago

New Features

Bugs Squashed

  • Fixed sidebar to include guides in docusaurus documentation (#238), thanks to @Sternakt

  • Fixed link to symbols in docusaurus docs (#227), thanks to @harishmohanraj

  • Removed bootstrap servers from constructor (#220), thanks to @kumaranvpl

faststream - v0.4.0

Published by davorrunje over 1 year ago

New Features

faststream - v0.3.1

Published by davorrunje over 1 year ago

  • README.md file updated
faststream - v0.3.0

Published by davorrunje over 1 year ago

New Features

  • Guide for fastkafka produces using partition key (#172), thanks to @Sternakt

    • Closes #161

  • Add support for Redpanda for testing and deployment (#181), thanks to @kumaranvpl

  • Remove bootstrap_servers from init and use the name of broker as an option when running/testing (#134)

  • Add a GH action file to check for broken links in the docs (#163)

  • Optimize requirements for testing and docs (#151)

  • Break requirements into base and optional for testing and dev (#124)

    • Minimize base requirements needed just for running the service.

  • Add link to example git repo into guide for building docs using actions (#81)

  • Add logging for run_in_background (#46)

  • Implement partition Key mechanism for producers (#16)

Bugs Squashed

  • Implement checks for npm installation and version (#176), thanks to @Sternakt

    • Closes #158 by checking if the npx is installed and more verbose error handling

  • Fix the helper.py link in CHANGELOG.md (#165)

  • fastkafka docs install_deps fails (#157)

    • Unexpected internal error: [Errno 2] No such file or directory: 'npx'

  • Broken links in docs (#141)

  • fastkafka run is not showing up in CLI docs (#132)

faststream - v0.3.0rc2

Published by davorrunje over 1 year ago

New Features

  • Add support for Redpanda for testing and deployment (#181), thanks to @kumaranvpl

  • Remove bootstrap_servers from init and use the name of broker as an option when running/testing (#134)

Bugs Squashed

  • Fix the helper.py link in CHANGELOG.md (#165)
faststream - v0.3.0rc0

Published by davorrunje over 1 year ago

New Features

  • Add a GH action file to check for broken links in the docs (#163)

  • Optimize requirements for testing and docs (#151)

  • Break requirements into base and optional for testing and dev (#124)

    • MInimize base requirements needed just for running the service.

Move to setup.py

  • Add link to example git repo into guide for building docs using actions (#81)

  • Add logging for run_in_background (#46)

  • Implement partition Key mechanism for producers (#16)

      • Implement partition key mechanism for @produces decorator
        Implemented behaviour:
    1. A method decorated with @produces can return defined message as-is: the message is wrapped in a Event object with key=None and passed to producer = message sent without defined key, partition chosen at random
    2. A method decorated with @produces can return defined message wrapped in an Event object with key argument value in bytes = message sent to kafka with defined key, partition chosen using the defined key

Bugs Squashed

  • fastkafka docs install_deps fails (#157)

    • Unexpected internal error: [Errno 2] No such file or directory: 'npx'

  • Broken links in docs (#141)

    • Looks nice! Btw: The links to your docs in your readme are broken:)

https://www.reddit.com/r/Python/comments/11paz9u/comment/jbz18oq/?utm_source=share&utm_medium=web2x&context=3

  • fastkafka run is not showing up in CLI docs (#132)
faststream - v0.2.3

Published by davorrunje over 1 year ago

  • Fixed broken links on PyPi index page
faststream - v0.2.2

Published by davorrunje over 1 year ago

New Features

  • Extract JDK and Kafka installation out of LocalKafkaBroker (#131)

  • PyYAML version relaxed (#119), thanks to @davorrunje

  • Replace docker based kafka with local (#68)

    • replace docker compose with a simple docker run (standard run_jupyter.sh should do)
    • replace all tests to use LocalKafkaBroker
    • update documentation

Bugs Squashed

  • Fix broken link for FastKafka docs in index notebook (#145)

  • Fix encoding issues when loading setup.py on windows OS (#135)

Package Rankings
Top 7.48% on Pypi.org
Related Projects
Propan

Propan is a powerful and easy-to-use Python framework for building event-driven applications that...

07 Dec 2021 486
fastapi-mvc

Developer productivity tool for making high-quality FastAPI production-ready APIs.

25 Jul 2021 580