This module provides a framework for handling and processing asynchronous tasks through message queues.
Project description
Message Queue Tasks
This module provides a framework for handling and processing asynchronous tasks through message queues.
Overview
- Utilizes the aio_pika library for AMQP message processing.
- Offers easy-to-use decorators and methods for defining tasks, producing and consuming them.
- Built with asynchronous patterns to allow seamless scalability.
Requirements
- Python 3.11+
- aio_pika library
- RabbitMQ or other AMQP broker
Usage
1. Defining a Task
To define a task, instantiate the MqTasks object and use the task decorator:
import mqtasks
mq_tasks = MqTasks(amqp_connection="amqp://localhost", queue_name="my_queue")
@mq_tasks.task(name="my_task")
def my_task_function(ctx: MqTaskContext):
# Process task
pass
mq_tasks.run()
2. Sending a Task
Instantiate MqTasksClient and use it to send a task:
import asyncio
import mqtasks
client = MqTasksClient(
loop=asyncio.get_event_loop(),
amqp_connection="amqp://localhost"
)
# define channel
channel = await client.queue(queue_name="my_queue")
#
result = await channel.run_task_async(task_name="my_task", body={"message":"hello world"})
Examples:
How to start example:
- Work dir:
./example
cd ./example
- Start RabbitMQ
docker pull rabbitmq:management
docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management
- Access the RabbitMQ management web UI:
http://localhost:15672/
- By default, the credentials are:
- Username: guest
- Password: guest
- Server
python example_server.py
- Client
python example_client.py
License
MIT License
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
mqtasks-0.0.1.dev19.tar.gz
(8.4 kB
view hashes)
Built Distribution
Close
Hashes for mqtasks-0.0.1.dev19-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 309d2555a1b74cafac9b97c7c01beefef91f4ede591bb2aea79c32e01527d35a |
|
MD5 | d7dc87e85f6af56b7c055485d67a7dfc |
|
BLAKE2b-256 | eed43839d9571e978dc4c0d211d50f4598342f371ca950ecf85818d66ece7d2d |