lsst-sqre / kafka-aggregator
A Kafka aggregator based on the Faust Python Stream Processing library
☆11Updated last year
Alternatives and similar repositories for kafka-aggregator:
Users that are interested in kafka-aggregator are comparing it to the libraries listed below
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆227Updated 2 weeks ago
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆68Updated 2 weeks ago
- Python Rest Client to interact against Schema Registry confluent server☆172Updated this week
- Faust dockerized application☆68Updated 2 years ago
- Python AsyncIO Services☆44Updated 10 months ago
- SQLAlchemy dialect for Turbodbc☆23Updated 8 months ago
- Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.☆40Updated 5 months ago
- Derivatives models written with the Tributary data flow library☆23Updated 3 months ago
- Event-driven data pipelines☆137Updated last year
- Sample Faust project to process tweets in real-time☆13Updated 3 years ago
- ByteHub: making feature stores simple☆60Updated 3 years ago
- Distributed process pool for Python☆111Updated 2 years ago
- An opinionated wrapper around FastAPI with custom microservice registration☆53Updated 3 years ago
- RedisTimeSeries python client☆99Updated 2 years ago
- Persist Pandas objects within a MongoDB database☆12Updated this week
- A quick POC for integrating FastAPI and Faust.☆52Updated 4 years ago
- Drop-in MessagePack support for ASGI applications and frameworks☆165Updated 11 months ago
- Simple, easy-to-use throttler for asyncio.☆120Updated 2 years ago
- A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.☆40Updated 5 years ago
- Fork of aio-libs/aiokafka☆27Updated last year
- simple, flexible, offline capable, cloud storage with a Python path-like interface☆173Updated 8 months ago
- Opentracing support for Starlette and FastApi☆65Updated 3 years ago
- Library/micro framework to create streaming applications with kafka in a fast way☆38Updated last week
- Python async multi-task communication library. Used by OctoBot project.☆21Updated last year
- TimescaleDB dialect driver for SQLAlchemy (psycopg2 and asyncpg supported)☆40Updated 6 months ago
- Python logging handler for Loki☆154Updated 9 months ago
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- Helm charts for Dask☆92Updated last week
- A consistent table management library in python☆160Updated last year