redqlite 1.0.0

A lightweight Messaging queue implementation using Redis for producer-worker-subscriber messaging.

RedQLite

A lightweight Messaging queue implementation using Redis for producer-worker messaging.

---

Features

• Redis-backed message queuing
• Producer and worker interface
• Lightweight and fast alternative to Kafka
• Works for long running tasks
• Provides configurable heartbeats from inside worker callback functions
• Redis server required
• Minimal setup — no Kafka or Zookeeper required

---

Installation

pip install redqlite

How It Works

This package simulates a basic Kafka-style messaging system using Redis lists. It includes:

A Producer that pushes messages to a Redis queue or broadcasts messages to all subscribers.

A Worker that consumes messages from the queue and processes them.

A Worker Pool to run concurrent workers.

A Subscriber that consumes messages from channel specific message queue.

Usage

Example: Producing a Message

# Import RQProducer class
from redqlite.producer import RQProducer

# Create a producer instance (assumes redis running on localhost:6379)
rqproducer = RQProducer()

# Send a message
rqproducer.send(topic="your_topic_name", message="hello world")

# Broadcast message on a channel
rqproducer.broadcast(channel="your_channel_name", message="hello world")

Example: Starting a Worker

# Import QWorker class
from redqlite.worker import RQWorker

def callback_func(msg, **kwargs):
	print(msg)

# Create a worker instance (assumes redis running on localhost:6379)
rqworker = RQWorker(topic="your_topic_name", callback=callback_func)

# Start worker thread
rqworker.start()

Example: Starting a subscriber

# Import QSubscriber class
from redqlite.subscriber import RQSubscriber

def callback_func(msg, **kwargs):
	print(msg)

# Create a worker instance (assumes redis running on localhost:6379)
rqsubscriber = RQSubscriber(channel="your_channel_name", callback=callback_func)

# Start subscriber thread
rqsubscriber.start()

License

This project is licensed under the MIT License - see the LICENSE file for details.

Contributing

Pull requests are welcome. For major changes, please open an issue first to discuss what you’d like to change.

Contact

Created by Shashank Gandhi – feel free to reach out by opening an issue or by contacting the author.