FastStream: Python's framework for Efficient Message Queue Handling

• fastkafka

  38 33 8.7 Jupyter Notebook

  FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.

  

Our journey with FastStream started when we needed to integrate our machine learning models into a customer's Apache Kafka environment. To streamline this process, we created FastKafka using AIOKafka, AsyncAPI, and asyncio. It was our first step in making message queue management easier.

• RabbitMQ

  92 11,590 10.0 Starlark

  Open source RabbitMQ: core server and tier 1 (built-in) plugins

  

Later, we discovered Propan, a library created by Nikita Pastukhov, which solved similar problems but for RabbitMQ. Recognizing the potential for collaboration, we joined forces with Nikita to build a unified library that could work seamlessly with both Kafka and RabbitMQ. And that's how FastStream came to be—a solution born out of the need for simplicity and efficiency in microservices development.

• WorkOS

  workos.com sponsored

  The modern identity platform for B2B SaaS. The APIs are flexible and easy-to-use, supporting authentication, user identity, and complex enterprise features like SSO and SCIM provisioning.

  

• aiokafka

  3 1,049 8.6 Python

  asyncio client for kafka

  

Our journey with FastStream started when we needed to integrate our machine learning models into a customer's Apache Kafka environment. To streamline this process, we created FastKafka using AIOKafka, AsyncAPI, and asyncio. It was our first step in making message queue management easier.

• Propan

  16 466 8.8 Python

  Propan is a powerful and easy-to-use Python framework for building event-driven applications that interact with any MQ Broker

Later, we discovered Propan, a library created by Nikita Pastukhov, which solved similar problems but for RabbitMQ. Recognizing the potential for collaboration, we joined forces with Nikita to build a unified library that could work seamlessly with both Kafka and RabbitMQ. And that's how FastStream came to be—a solution born out of the need for simplicity and efficiency in microservices development.

• faststream-gen

  3 32 9.3 Jupyter Notebook

  The faststream-gen library uses advanced AI to generate FastStream code from user descriptions, speeding up FastStream app development.

  

Built for Automatic Code Generation: FastStream is optimized for automatic code generation using advanced models like GPT. This means you can leverage the power of code generation to boost your productivity. Checkout the amazing tool we built for the microservice code generation: faststream-gen.

• cookiecutter

  56 21,572 8.6 Python

  A cross-platform command-line utility that creates projects from cookiecutters (project templates), e.g. Python package projects, C projects.

  

Install the cookiecutter package using the following command:

• spec

  42 3,853 7.9 JavaScript

  The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs. (by asyncapi)

  

Our journey with FastStream started when we needed to integrate our machine learning models into a customer's Apache Kafka environment. To streamline this process, we created FastKafka using AIOKafka, AsyncAPI, and asyncio. It was our first step in making message queue management easier.

• InfluxDB

  www.influxdata.com sponsored

  Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.

  

• cookiecutter-faststream

  1 9 6.1 Python

  Cookiecutter template for FastStream apps

  

cookiecutter https://github.com/airtai/cookiecutter-faststream.git

• faststream

  13 1,779 9.7 Python

  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.

  

Ready to join the FastStream revolution? Head over to our GitHub repository and show your support by starring it. By doing so, you'll stay in the loop with the latest developments, updates, and enhancements as we continue to refine and expand FastStream.

• ApacheKafka

  104 28 0.0

  A curated re-sources list for awesome Apache Kafka

Our journey with FastStream started when we needed to integrate our machine learning models into a customer's Apache Kafka environment. To streamline this process, we created FastKafka using AIOKafka, AsyncAPI, and asyncio. It was our first step in making message queue management easier.

• pydantic

  167 18,617 9.8 Python

  Data validation using Python type hints

  

Also, FastStream uses Pydantic to parse input JSON-encoded data into Python objects, making it easy to work with structured data in your applications, so you can serialize your input messages just using type annotations.

Suggest a related project