rwhitten577 / faust-example
Example of using Faust with Docker
☆23Updated 5 years ago
Alternatives and similar repositories for faust-example:
Users that are interested in faust-example are comparing it to the libraries listed below
- Faust dockerized application☆68Updated 2 years ago
- A quick POC for integrating FastAPI and Faust.☆52Updated 4 years ago
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- Python Rest Client to interact against Schema Registry confluent server☆172Updated this week
- Sample Faust project to process tweets in real-time☆13Updated 3 years ago
- REST-like API exposing Airflow data and operations☆61Updated 6 years ago
- Helpers & syntactic sugar for PySpark.☆61Updated last year
- A Getting Started Guide for developing and using Airflow Plugins☆94Updated 6 years ago
- Use Airflow to move data from multiple MySQL databases to BigQuery☆100Updated 4 years ago
- Built a stream processing data pipeline to get data from disparate systems into a dashboard using Kafka as an intermediary.☆29Updated last year
- Fork of aio-libs/aiokafka☆27Updated last year
- event-triggered plugins for airflow☆21Updated 5 years ago
- Code examples for "Asyncio Coroutine Patterns"☆75Updated 6 years ago
- SQLAlchemy dialect for Turbodbc☆23Updated 8 months ago
- A pandas.DataFrame-based ORM.☆85Updated 2 years ago
- Apache Avro <-> pandas DataFrame☆136Updated 6 months ago
- locopy: Loading/Unloading to Redshift and Snowflake using Python.☆106Updated this week
- Elasticsearch tool for easily collecting and batch inserting Python data and pandas DataFrames☆21Updated 5 years ago
- Celery extension which allows to orchestrate 100/1000/10000 tasks combined into a complex workflow☆99Updated last year
- SQL on dataframes - pandas and dask☆64Updated 6 years ago
- An opinionated wrapper around FastAPI with custom microservice registration☆53Updated 3 years ago
- Stream Processing Made Easy☆39Updated 2 years ago
- Asynchronous actions for PySpark☆47Updated 3 years ago
- dagster scikit-learn pipeline example.☆44Updated last year
- Slack notifications for the Luigi workflow manager☆46Updated 3 years ago
- pytest plugin to run the tests with support of pyspark☆84Updated 11 months ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆227Updated 2 weeks ago
- Flask Dashboard - Modular Admin Design | AppSeed☆60Updated last year
- ASGI middleware to record and emit timing metrics (to something like statsd)☆126Updated last year
- A xlsx and html rendering library for rendering data available in Pandas DataFrames.☆26Updated 8 months ago