AsyncRedisCommandQueue

Async Redis command queue.

AsyncRedisCommandQueue

AsyncRedisCommandQueue - Асинхронный класс для работы с Redis.

Пример

import asyncio
from qtasks import QueueTasks
from qtasks.contrib.redis import AsyncRedisCommandQueue

redis_contrib = AsyncRedisCommandQueue(redis)
asyncio.run(redis_contrib.execute("hset", kwargs["name"], mapping=kwargs["mapping"]))

__init__(redis, log=None)

Экземпляр класса.

Parameters:

Name	Type	Description	Default
redis	Redis	класс Redis.	required
log	Logger	класс qtasks.logs.Logger. По умолчанию: qtasks._state.log_main.	None

execute(cmd, *args, **kwargs) async

Запрос в Redis.

Parameters:

Name	Type	Description	Default
cmd	str	Команда.	required
args(tuple,	optional	Параметры к команде через *args.	required
kwargs(dict,	optional	Параметры к команде через *args.	required