Consumer Python Packages

pyrmq

Python with RabbitMQ—simplified so you won't have to.

rejected

rejected is a consumer framework for RabbitMQ

td-ameritrade-python-api

Unofficial Python API client library for TD Ameritrade. This library allows for easy access of the Standard API and allows users to build data pipelines for the Streaming API.

aiokafka-foundation-kit

Async Kafka foundation kit built on aiokafka — lifecycle helpers, Pydantic settings, DI integrations

kafka-influxdb

High performance Kafka consumer for InfluxDB. Supports collectd message formats.

aws-kinesis-consumer

Consume an AWS Kinesis Data Stream to look over the records from a terminal.

tyo-mq-client

Python client for tyo-mq: pub/sub with durable ACK/retry delivery, topic wildcards, consumer groups, and auth realms

pulsar-queue

Asynchronous message queue consumer and scheduler

channels-simplify

Very simple prototyping of your complex websockets

pydrinker-gcp

Google Cloud Platform "plugin" for pydrinker

turbomq

A lightweight message queue engine

domba

DOMBA KNOT

kinesis-stream-consumer

Kinesis consumer channelize through redis along with aws autorefreshable session

rabbitleap

Simple RabbitMQ consuming framework