Libraries & frameworks
faust
faust-streaming/faust
Faust is a Python stream processing library that brings Kafka Streams ideas to Python, with asyncio-based event processing, distributed tables and durable state stores.
Topics
Related projects
faststream5.4kAn asynchronous Python framework for event-driven services, offering FastAPI-like ergonomics over Kafka, RabbitMQ, NATS, Redis, and MQTT brokers.
workflow14.4kSogou C++ Workflow is a lightweight, high-performance asynchronous networking and parallel computing framework. It provides HTTP, Redis, MySQL, and Kafka clients, DAG task orchestration, and service governance primitives.
arq3karq is a Python job queue and RPC library built on asyncio and Redis. It lets async applications schedule background jobs and distributed tasks.
go-streams2.2kA lightweight Go stream-processing library whose declarative DSL composes sources, flows and sinks into data pipelines, with built-in map, filter, windowing and throttling operators plus Kafka, Redis and WebSocket connectors.
aiocache1.4kAn asyncio cache manager for Python offering one simple interface over memory, Redis and Memcached backends, plus serializers, decorators and plugin hooks.
redis-om-python1.3kRedis OM for Python: a declarative object-mapping library that uses Pydantic models to validate, persist, index and query data stored in Redis.