ag2ai/faststream 0.2.10

v0.2.10

on GitHub

What's Changed

Now, you can hide your connection secrets in the AsyncAPI schema by manually setting up the server URL:

broker = RabbitBroker(
    "amqp://guest:guest@localhost:5672/",  # Connection URL
    asyncapi_url="amqp://****:****@localhost:5672/",  # Public schema URL
)

Additionally, the RabbitMQ AsyncAPI schema has been improved, adding support for faststream.security, and the connection scheme is now defined automatically.

RabbitMQ connection parameters are now merged, allowing you to define the main connection data as a URL string and customize it using kwargs:

broker = RabbitBroker(
    "amqp://guest:guest@localhost:5672/",
    host="127.0.0.1",
)

# amqp://guest:guest@127.0.0.1:5672/ - The final URL

• A more suitable faststream.security import instead of faststream.broker.security
• chore: add release notes for 0.2.9 by @kumaranvpl in #894
• chore: upgrade packages by @davorrunje in #901
• chore: use js redirect and redirect to version by @kumaranvpl in #902
• feat: add asyncapi_url broker arg by @Lancetnik in #903

Full Changelog: 0.2.9...0.2.10