Kafka-based Job Queue for Python
-
Updated
Feb 4, 2022 - Python
Kafka-based Job Queue for Python
Small Flask app with scalable, asynchronous backend workers deployed on Kubernetes.
Distributed task redisqueue(最简单python分布式函数调度框架)
a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server
consumer/producer/rpc library built over aioamqp
Lightweight Module for Asynchronous Event Driven Systems
Efficient Pandas and Ray Kafka Producer for python using actor model.
It will take backup of given topic and store that into either local filesystem or S3.It will also restore from given local filesystem or S3.
Contains various design strategies with the implementation of them on a small level with an example. This repo helps us to understand how and why one should implement various designs while creating applications.
A python multiprocess program in which processes can be synchronized remotely using python remote manager
async pub/sub and polling-publisher rabbit client
A Guide to setup Kafka with Python in less than 5 minutes
FastAPI websocket producer-consumer demonstration with asyncio.Queue.
A real time stock prices tracker using Kafka
Extract cryptocurrency addresses from big datasets
Message passing mailboxes for IPC between task producers and consumers
getDomainAge is a web application which can provide the age of a given domain name. The intention of this project is to demonstrate flask for API development, SQLAlchemy for ORM and beautifulsoup for HTML parsing.
Add a description, image, and links to the producer-consumer topic page so that developers can more easily learn about it.
To associate your repository with the producer-consumer topic, visit your repo's landing page and select "manage topics."