Python Stream Processing
-
Updated
Nov 23, 2023 - Python
Python Stream Processing
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Python Stream Processing. A Faust fork
450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Consul, Spark, Jenkins, Travis CI, Git, MySQL, Linux, DNS, Whois, SSL Certs, Yum Security Updates, Kubernetes, Cloudera etc...
Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
Example end to end data engineering project.
100% Python stream processing with Streaming DataFrames
docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform
后端面试题汇总(Python、Redis、MySQL、PostgreSQL、Kafka、数据结构、算法、编程、网络)
pip install funboost,python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件,支持如 celery dramatiq等框架整体作为funboost中间件,python函数加速器,框架包罗万象,用户能想到的控制功能全都有。一统编程思维,兼容50% python业务场景,适用范围广。只需要一行代码即可分布式执行python一切函数,99%用过funboost的pythoner 感受是 简易 方便 强劲 强大,相见恨晚 。
Kafka-based Job Queue for Python
Streaming reactive and dataflow graphs in Python
Add a description, image, and links to the kafka topic page so that developers can more easily learn about it.
To associate your repository with the kafka topic, visit your repo's landing page and select "manage topics."