producers & consumers for message queues in a simplified way
parsing, networking, and documentation generation
your workflow & accelerate your progress
FastStream provides a unified API to work across multiple message brokers (Kafka, RabbitMQ, NATS, support)
Leverage Pydantic's validation capabilities to serialize and validates incoming messages
Stay ahead with automatic AsyncAPI documentation
Full-typed editor support makes your development experience smooth, catching errors before they reach runtime
Manage your service dependencies efficiently with FastStream's built-in DI system
Supports in-memory tests, making your CI/CD pipeline faster and more reliable
Use extensions for lifespans, custom serialization and middleware
FastStream is fully compatible with any HTTP framework you want (FastAPI especially)
FastStream is optimized for automatic code generation using advanced models like GPT and Llama
New Blog Post | Streamlining Asynchronous Services with FastStream 🌟
For the NATS Python client users, check out this community contribution from @airt_AI. FastStream streamlines the entire process of working with message queues in microservices.
Looks very interesting. Going to have a look when I'm done with my current project!
Hell yeah, I've been wondering about good ways to setup streams with FastAPI... will have to try this out next time I get a good project fit
This looks really cool - as someone who had to create a distributed application using rabbitmq and aiopika - this would have saved me alot of time - I love the decorations for pub sub.
This is fantastic. I've been looking for something with asyncio support to replace celery. Big plus that it supports rabbitMQ and kafka.
Congrats on trending in the Python category on GitHub! 🎉 Your FastStream framework seems awesome and useful! Way to go! 💪 #achievement