ag2ai/faststream 0.3.0

v0.3.0

on GitHub

What's Changed

The main feature of the 0.3.0 release is added Redis support by @Lancetnik in #1003

You can install it by the following command:

pip install "faststream[redis]"

Here is a little code example

from faststream import FastStream, Logger
from faststream.redis import RedisBroker

broker = RedisBroker()
app = FastStream(broker)

@broker.subscriber(
    channel="test",  # or
    # list="test",     or
    # stream="test",
)
async def handle(msg: str, logger: Logger):
    logger.info(msg)

Other features

• feat: show reload directories with --reload flag by @Lancetnik in #981
• feat: implement validate and no_ack subscriber options (#926) by @mihail8531 in #988
• other features by @Lancetnik in #1003
  • Improve error logs (missing CLI arguments, undefined starting)
  • Add faststream docs serve --reload ... option for documentation hotreload
  • Add faststream run --reload-extension .env option to watch by changes in such files
  • Support faststream run -k 1 -k 2 ... as k=["1", "2"] extra options
  • Add subscriber, publisher and router include_in_schema: bool argument to disable AsyncAPI render
  • remove watchfiles from default distribution
  • Allow create broker.publisher with already running broker
  • FastAPI-like lifespan FastStream application context manager
  • automatic TestBroker(connect_only=...) argument based on AST
  • add NatsMessage.in_progress() method

Testing

• test: improve coverage by @Lancetnik in #983

Documentation

• docs: fix module name in NATS example by @SepehrBazyar in #993
• docs: Update docs to add how to customize asyncapi docs by @kumaranvpl in #999
• docs: polish Redis pages by @Lancetnik in #1005
• docs: bump docs to the new taskiq-faststream version by @Lancetnik in #1009

Chore

• chore: add broken link checker by @kumaranvpl in #985
• chore: disable verbose in check broken links workflow by @kumaranvpl in #986
• chore: add left out md files to fix broken links by @kumaranvpl in #987
• chore: update mike workflow to use config by @Lancetnik in #982
• chore: add workflow to update release notes automatically by @kumaranvpl in #992
• chore: pip packages version updated by @davorrunje in #998
• chore: create PR to merge updated release notes by @kumaranvpl in #1004

New Contributors

• @SepehrBazyar made their first contribution in #993
• @mihail8531 made their first contribution in #988

Full Changelog: 0.2.15...0.3.0