qtasks 1.2.0

Queue Tasks Framework

QTasks - Фреймворк для очередей задач.

Документация: https://txello.github.io/qtasks/

PyPI: https://pypi.org/project/qtasks/

QueueTasks — это современный фреймворк для асинхронной обработки задач, разработанный с упором на простоту, гибкость и расширяемость. Он легко интегрируется в проекты любого масштаба и подходит как новичкам, так и опытным разработчикам.

Особенности

• Простой — Легко настраивается и быстро осваивается. Интуитивный API и понятная структура проекта.
• Настраиваемый — Каждый компонент можно заменить или адаптировать под свои нужды. Вы управляете логикой выполнения.
• Расширяемый — Поддержка плагинов и модулей позволяет легко добавлять новые возможности и интеграции.

Установка

Базовая установка (Redis по умолчанию)

pip install qtasks

Установка с поддержкой других брокеров

RabbitMQ

pip install qtasks[rabbitmq]

Kafka

pip install qtasks[kafka]

Пример

from qtasks import QueueTasks

app = QueueTasks()

@app.task(name="mytest") # Пример обычной задачи
def mytest(text: str):
    print(text)
    return text

@app.task(name="error_zero") # Пример задачи с ошибкой
def error_zero():
    result = 1/0
    return

app.run_forever()

# Вызов задачи:
# app.add_task("mytest", args=("Тест",))