lsst-sqre / kafka-aggregator
A Kafka aggregator based on the Faust Python Stream Processing library
☆11Updated last year
Related projects ⓘ
Alternatives and complementary repositories for kafka-aggregator
- A Cookiecutter template for creating Faust projects quickly.☆70Updated last year
- Faust dockerized application☆68Updated last year
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆64Updated this week
- Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.☆37Updated 2 months ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆219Updated this week
- Python Rest Client to interact against Schema Registry confluent server☆170Updated this week
- Our docker-in-docker image with Python☆14Updated last month
- ByteHub: making feature stores simple☆58Updated 3 years ago
- Python AsyncIO Services☆42Updated 7 months ago
- Sample Faust project to process tweets in real-time☆13Updated 3 years ago
- Derivatives models written with the Tributary data flow library☆22Updated this week
- RedisTimeSeries python client☆99Updated last year
- Library/micro framework to create streaming applications with kafka in a fast way☆36Updated this week
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- SQLAlchemy dialect for Turbodbc☆23Updated 5 months ago
- Simple, easy-to-use throttler for asyncio.☆119Updated 2 years ago
- An opinionated wrapper around FastAPI with custom microservice registration☆53Updated 3 years ago
- Persist Pandas objects within a MongoDB database☆13Updated this week
- Asyncio-based Python library for working with aiokafka, Confluent Schema Registry, and Kafka Broker APIs.☆22Updated this week
- JSON Logging for Sanic☆10Updated 3 years ago
- Distributed process pool for Python☆110Updated 2 years ago
- A test showing TimescaleDB integrated into a Django application☆15Updated 4 years ago
- Drop-in MessagePack support for ASGI applications and frameworks☆161Updated 8 months ago
- Opionated helpers for creating py.test fixtures for Docker integration and smoke testing environments☆84Updated 3 months ago
- ☆69Updated last week
- Python bindings for RocksDB used by faust-streaming☆24Updated last year
- Simple YAML configuration file parser☆78Updated 4 months ago
- Prometheus middleware for Starlette and FastAPI☆38Updated 3 years ago
- ConfZ is a configuration management library for Python based on pydantic.☆228Updated 4 months ago
- A simple Declarative ORM for Redis using pydantic Models☆43Updated 4 months ago