Я запускаю некоторые задачи через django-celery (с rabbitmq в качестве бэкэнда), задачи требуют много времени и интенсивно используют процессор. У меня есть 2 рабочих экземпляра Ec2 (один маленький, а другой - средний по процессору). Я настроил...

Могу ли я иметь несколько машин для выполнения задач и возврата сообщений, распространяемых django? Я просмотрел celery/rabbitmq, я не уверен, смогу ли я настроить сельдерейных рабочих на удаленных компьютерах. Может ли кто-нибудь провести меня...

Я использую django-celery для задач, которые выполняются дольше, чем обычно. Все время, пока задача выполняется, клиент проверяет результат текущей задачи. Проблема в том, что если celeryd не запускается или завершается из-за какой-то ошибки,...

У меня есть фляжное веб-приложение, развернутое в героку. Мне нужно запланировать выполнение фоновой задачи в определенное время. Я попытался использовать модуль apscheduler . Хотя это позволяет определять периодические задачи, легко добавляя их...

Некоторые кортежи в моей базе данных нужно стереть через определенное время. Мне нужно мое приложение django, чтобы проверить, не истек ли срок действия строк. Хотя я определенно могу написать функцию, как мне заставить Django запускаться каждый...

У меня есть Django + Celery в Heroku, а Celery настроен как: import djcelery djcelery.setup_loader() BROKER_URL = "django://" # tell kombu to use the Django database as the message queue CELERYBEAT_SCHEDULER =...

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

Я следую этому руководству: http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html Мой файл proj.celery: from __future__ import absolute_import, unicode_literals import os from celery import Celery from celery.schedules...

Проблемы: я использую сервер rabbitmq с сельдереем Мне нужно запустить несколько задач в фоновом режиме. Что я могу сделать Когда каждая задача завершена, мне нужно отобразить html-страницу, чтобы запустить html-страницу, мне нужен объект...

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

from my_celery import app from delete_duplicate import DeleteDuplicate import celery class CallbackTask(celery.Task): def on_success(self, retval, task_id, args, kwargs): print "Task id: ", task_id print "retval ", retval...

Я реализую модуль напоминания в приложении, используя Django celery-beat , я создаю вкладку cron в периодических задачах и передаче словаря в параметре kwargs . Он успешно сохранен в таблице периодических задач Django, но когда запланированная...

В моем текущем проекте мне нужно получить данные с более чем 700 конечных точек, а затем отправить эти данные еще на более чем 700 конечных точек. Мой подход состоит в том, чтобы использовать Django Celery Redis, поставить более 70 конечных точек на...