BWStearns / faust_joins
join things in faust
☆15Updated 3 years ago
Alternatives and similar repositories for faust_joins:
Users that are interested in faust_joins are comparing it to the libraries listed below
- Python Rest Client to interact against Schema Registry confluent server☆173Updated last week
- Faust dockerized application☆68Updated 2 years ago
- A simple demonstration of an event driven microservice written in Python☆79Updated 9 years ago
- Example of using Faust with Docker☆23Updated 5 years ago
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- A quick POC for integrating FastAPI and Faust.☆51Updated 4 years ago
- Fork of aio-libs/aiokafka☆27Updated last year
- REST-like API exposing Airflow data and operations☆61Updated 6 years ago
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- ☆28Updated 6 months ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆230Updated last week
- Asyncio-based Python library for working with aiokafka, Confluent Schema Registry, and Kafka Broker APIs.☆22Updated this week
- FastAPI Simple application structure☆36Updated 4 years ago
- Example for an airflow plugin☆49Updated 8 years ago
- PostgreSQL CDC library using pgoutput and python☆75Updated 11 months ago
- An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka☆27Updated last month
- Dynamic ORM operations using pydantic☆29Updated 2 years ago
- Bare minimal Airflow on Kubernetes (Local, EKS, AKS)☆52Updated 5 years ago
- a declarative ETL framework that enforces data engineer best practices☆39Updated 7 years ago
- Convert JSON files to Parquet using PyArrow☆96Updated last year
- Fast iterative local development and testing of Apache Airflow workflows☆197Updated 3 months ago
- A client for the Confluent Schema Registry API implemented in Python☆21Updated 6 years ago
- Airflow plugin to transfer arbitrary files between operators☆78Updated 6 years ago
- Helpers & syntactic sugar for PySpark.☆61Updated last year
- A Getting Started Guide for developing and using Airflow Plugins☆93Updated 6 years ago
- A pandas.DataFrame-based ORM.☆85Updated 3 years ago
- A fast BSON to MongoDB Extended JSON converter for Python - This Repository is NOT a supported MongoDB product☆40Updated last week
- https://rogulski.it/blog/sqlalchemy-14-async-orm-with-fastapi/☆64Updated 2 years ago
- fast data loading with binary copy☆114Updated 2 weeks ago
- Elasticsearch tool for easily collecting and batch inserting Python data and pandas DataFrames☆21Updated 5 years ago