AsyncRedisBroker

Async Redis Broker.

`AsyncRedisBroker` ¶

Bases: BaseBroker, AsyncPluginMixin

Брокер, слушающий Redis и добавляющий задачи в очередь.

Пример¶

from qtasks import QueueTasks
from qtasks.brokers import AsyncRedisBroker

broker = AsyncRedisBroker(name="QueueTasks", url="redis://localhost:6379/2")

app = QueueTasks(broker=broker)

`init(name='QueueTasks', url=None, storage=None, queue_name='task_queue', log=None, config=None)` ¶

Инициализация AsyncRedisBroker.

Parameters:

Name	Type	Description	Default
`name`	`str`	Имя проекта. По умолчанию: "QueueTasks".	`'QueueTasks'`
`url`	`str`	URL для подключения к Redis. По умолчанию: None.	`None`
`storage`	`BaseStorage`	Хранилище. По умолчанию: None.	`None`
`queue_name`	`str`	Имя массива очереди задач для Redis. По умолчанию: "task_queue".	`'task_queue'`
`log`	`Logger`	Логгер. По умолчанию: None.	`None`
`config`	`QueueConfig`	Конфиг. По умолчанию: None.	`None`

`add(task_name, priority=0, extra=None, args=None, kwargs=None)` `async` ¶

Добавляет задачу в брокер.

Parameters:

Name	Type	Description	Default
`task_name`	`str`	Имя задачи.	required
`priority`	`int`	Приоритет задачи. По умоланию: 0.	`0`
`extra`	`dict`	Дополнительные параметры задачи.	`None`
`args`	`tuple`	Аргументы задачи типа args.	`None`
`kwargs`	`dict`	Аргументы задачи типа kwargs.	`None`

Returns:

Name	Type	Description
`Task`	`Task`	`schemas.task.Task`

`flush_all()` `async` ¶

Удалить все данные.

`get(uuid)` `async` ¶

Получение информации о задаче.

Parameters:

Name	Type	Description	Default
`uuid`	`UUID \| str`	UUID задачи.	required

Returns:

Type	Description
`Task \| None`	Task\|None: Если есть информация о задаче, возвращает `schemas.task.Task`, иначе `None`.

`listen(worker)` `async` ¶

Слушает очередь Redis и передаёт задачи воркеру.

Parameters:

Name	Type	Description	Default
`worker`	`BaseWorker`	Класс воркера.	required

`remove_finished_task(task_broker, model)` `async` ¶

Обновляет данные хранилища через функцию self.storage.remove_finished_task.

Parameters:

Name	Type	Description	Default
`task_broker`	`TaskPrioritySchema`	Схема приоритетной задачи.	required
`model`	`TaskStatusNewSchema \| TaskStatusErrorSchema`	Модель результата задачи.	required

`start(worker)` `async` ¶

Запускает брокер.

Parameters:

Name	Type	Description	Default
`worker`	`BaseWorker`	Класс Воркера.	required

`stop()` `async` ¶

Останавливает брокер.

`update(**kwargs)` `async` ¶

Обновляет информацию о задаче.

Parameters:

Name	Type	Description	Default
`kwargs`	`dict`	данные задачи типа kwargs.	`{}`

AsyncRedisBroker