Event Driven Architecture Python Packages

faststream

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

fastapi-cloudevents

CloudEvents FastAPI plugin. Allows to easily consume and produce events in CloudEvents format over REST API.

quixstreams

Python Streaming DataFrames for Kafka

python-cqrs

Event-Driven Architecture Framework

ankka

A serverless platform for agentic AI on Apache Pekko. Write entities, workflows, agents and endpoints in Scala, Python, TypeScript or Rust, test them without a runtime, and deploy them to Kubernetes with one CLI.

solace-agent-mesh

An event-driven framework designed to build and orchestrate multi-agent AI systems. It enables seamless integration of AI agents with real-world data sources and systems, facilitating complex, multi-step workflows.

jam-py-v7

Low code, web front-end generator and event driven platform for creating database applications with a Web interface in minutes. Supports SQLite, SQLCipher, PostgreSQL, MySQL, Firebird, MSSQL, Oracle, DB2, DuckDB, Docker, and more 🚀. Jam.py, the low code, more-code platform you'll enjoy using ⚡

littlehorse-client

LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents

infinity-bus

Middleware-native async event bus — extensible, type-safe, one dependency.

adhoccomputing

This is an event-driven asynchronous component model developed in Python. This library can be used to design and implement component-based ad hoc and distributed computing models and algorithms.

event-notifier

Simple python notifier (also known as emitter or dispatcher).

napalm-logs

Cross-vendor normalisation for network syslog messages, following the OpenConfig and IETF YANG models

kafka-mcp-enterprise

A production-ready Model Context Protocol (MCP) server for Apache Kafka. Features Information Flow Control (IFC) sandboxing, granular namespace isolation, and strict bounded buffers to securely bridge autonomous AI agents with enterprise streaming infrastructure.

pyensign

Ensign driver, SDK, and helpers for Python

fast-kafka-api

Asynchronous Python framework for event-driven services. A thin client for Kafka, RabbitMQ, NATS, Redis and MQTT with full access to native broker features, plus AsyncAPI docs, in-memory tests and observability out of the box.

alpheast

An event-driven backtesting engine for trading strategies

python-outbox

Outbox pattern implementation in Python

pynetevents

A python implementation of C# style events

tokeo

tokeo redefines efficiency in event-driven architecture. Harnessing the strengths of Cement for fast CLI apps, Dramatiq for reliable task processing, repeating tasks with APScheduler, gRPC for external access and governed AI agents.