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
- Python Rest Client to interact against Schema Registry confluent server☆171Updated this week
- REST-like API exposing Airflow data and operations☆61Updated 6 years ago
- This is a pytest plugin that enables you to test your code that relies on a running Elasticsearch search engine. It allows you to specify…☆68Updated this week
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- Sample Faust project to process tweets in real-time☆13Updated 3 years ago
- A quick POC for integrating FastAPI and Faust.☆52Updated 3 years ago
- event-triggered plugins for airflow☆21Updated 5 years ago
- Convert JSON files to Parquet using PyArrow☆95Updated last year
- SQL on dataframes - pandas and dask☆64Updated 6 years ago
- AintQ Is Not Task Queue - a Python asyncio task queue on PostgreSQL.☆50Updated 2 years ago
- Handle many API calls from a single HTTP request☆55Updated 6 years ago
- aioch - is a library for accessing a ClickHouse database over native interface from the asyncio☆163Updated 2 years ago
- Python Driver for Apache Drill.☆58Updated last year
- A curated list of all the awesome examples, articles, tutorials and videos for Apache Airflow.☆96Updated 4 years ago
- Example for an airflow plugin☆49Updated 8 years ago
- Airflow plugin to transfer arbitrary files between operators☆78Updated 6 years ago
- Scrapy extension which writes crawled items to Kafka☆30Updated 6 years ago
- A basic Python-based publishing platform based around the idea of commonplace books☆29Updated last year
- An extension for GINO to support Starlette server.☆78Updated 2 years ago
- Flake8 plugin that checks SQL code against opinionated style rules☆26Updated 2 years ago
- Asynchronous actions for PySpark☆47Updated 3 years ago
- ☆10Updated 6 years ago
- Stream Processing Made Easy☆38Updated 2 years ago
- Celery extension which allows to orchestrate 100/1000/10000 tasks combined into a complex workflow☆97Updated last year
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- Prometheus metrics for Sanic, an async python web server☆80Updated last year
- ASGI middleware to record and emit timing metrics (to something like statsd)☆126Updated last year
- Swiple enables you to easily observe, understand, validate and improve the quality of your data☆82Updated this week
- A fully-featured multi-source data pipeline for continuously extracting knowledge from COVID-19 data.☆21Updated 3 years ago