У меня есть одно приложение django, которое позволяет пользователю создавать несколько разных блогов. Каждый блог должен собирать модельные данные (например, количество посещений, кликов и т. д.) ежечасно/ежедневно/еженедельно и т. д., а интервал...

Я пытаюсь связать следующие задачи с сельдереем (v4.0), task = group([tasks1.s(), task2.s()) | generate_job_requests.s() | execute_job.map() | aggregate_result.s() result = task.get() Вышеупомянутая часть работает нормально до...

У меня есть базовый класс, например: class Auto(object): _year = None _base_price = None @classmethod def calculate_price(cls): return cls._base_price + 5000 * (2016 - cls._year) class BMW(Auto): _year = 2015...

Я хочу знать, есть ли способ отслеживать, завершается ли задача или нет, как только она выполняется с использованием сельдерея python. У меня есть событие, которое я хочу запустить на основе результатов определенной задачи.

Я очень смущен, глядя на разные способы создания задачи сельдерея. На первый взгляд все они работают одинаково Итак, может ли кто-нибудь объяснить, в чем разница между ними. 1. from myproject.tasks import app @app.task def foo(): pass...

Я использую celery-flask для постановки в очередь и мониторинга задачи, у меня есть от четырех до пяти сценариев, и я хочу, чтобы эти сценарии выполнялись как задача celery, передавая сценарий через сервер flask, а затем отслеживая их состояние. Вот...

Задача с bind=True У меня есть задача сельдерея, которая выполняет вычисление, длящееся несколько секунд. from celery import states @celery.task(name="crunch.task", bind=True) def crunch(self, data): try: pass #...