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.2.tar.gz
(4.6 kB
view hashes)
Built Distribution
Close
Hashes for taskiq_redis-0.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1f4e0822c492e38d7828429518d73b324096f1537c44a3a5a6afffc489d3f1b1 |
|
MD5 | b622879f531c0208fdb5bbb079d64394 |
|
BLAKE2b-256 | 89b2464e2e96f8a9d512c9a4e1717717cb4ef92a79fcf81ac93b8ccccde55832 |