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.4.tar.gz
(4.7 kB
view hashes)
Built Distribution
Close
Hashes for taskiq_redis-0.0.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b2b039d9a638f914fe7113306c28db83d6bd4380afeaf3356500aa4f7dda592b |
|
MD5 | 463b04c214e46c8fc2964e16a8661c90 |
|
BLAKE2b-256 | c8c8cfebd6e61a75d64f7b77fa4b0adce1f1f5472642dcb16d02a9d841b6a2ac |