Redis integration for taskiq
Project description
TaskIQ-Redis
Taskiq-redis is a plugin for taskiq that adds a new broker and result backend based on redis.
Installation
To use this project you must have installed core taskiq library:
pip install taskiq
This project can be installed using pip:
pip install taskiq-redis
Usage
Let's see the example with the redis broker and redis async result:
import asyncio
from taskiq_redis.redis_broker import RedisBroker
from taskiq_redis.redis_backend import RedisAsyncResultBackend
redis_async_result = RedisAsyncResultBackend(
url="redis://localhost:6379",
)
broker = RedisBroker(
url="redis://localhost:6379",
result_backend=redis_async_result,
)
@broker.task
async def best_task_ever() -> None:
"""Solve all problems in the world."""
await asyncio.sleep(5.5)
print("All problems are solved!")
async def main():
task = await my_async_task.kiq()
print(await task.get_result())
asyncio.run(main())
RedisBroker configuration
RedisBroker parameters:
url
- url to redis.task_id_generator
- custom task_id genertaor.result_backend
- custom result backend.queue_name
- name of the pub/sub channel in redis.max_connection_pool_size
- maximum number of connections in pool.
RedisAsyncResultBackend configuration
RedisAsyncResultBackend parameters:
url
- url to redis.
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
taskiq-redis-0.0.3.tar.gz
(4.6 kB
view hashes)
Built Distribution
Close
Hashes for taskiq_redis-0.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 70037745d54e1fdc0de811bdf9f1a0911717ae221131ae7b2963a8790bedb10c |
|
MD5 | 369e88e19c5bef62a5d8346b0f2c640b |
|
BLAKE2b-256 | fbe5c3ebbe722fd8a1cae4911892182e0f0828d2beb5482d7024fff1a5ca628c |