Результаты поиска по запросу "celery"
Увеличьте время повтора сельдерея в каждом цикле повтора
Я делаю повторы с сельдереем, как в Docs-примере: @task() def add(x, y): try: ... except Exception, exc: add.retry(exc=exc, countdown=60) # override the default and # retry in 1 minuteКак я могу увеличивать время повторного отсчета каждый раз, ...
Зачем нам нужны брокеры сообщений, такие как RabbitMQ, через базу данных, такую как PostgreSQL?
Я новичок в таких сообщениях, как брокерыRabbitMQ [https://www.rabbitmq.com/] который мы можем использовать для создания задач / очередей сообщений для системы планирования, такой какСельдерей [http://www.celeryproject.org/]. Теперь вот ...
Как я могу просмотреть поставленные в очередь задачи в RabbitMQ?
Я использую RabbitMQ в качестве своего брокера сообщений, и мои работники - задачи Celery. Я пытаюсь диагностировать проблему, в которой я ставлю задачи в очередь на RabbitMQ, но Celery не отвечает. Есть ли способ проверить, какие задачи ...
очистка сельдерея с помощью базы данных
Я пытаюсь понять, как и когда задачи убираются в сельдерее. Смотря на документация по заданию [http://docs.celeryproject.org/en/latest/userguide/tasks.html#rabbitmq-result-backend] Я вижу это: Старые результаты будут очищены автоматически в ...
Как связать задачу Celery, которая возвращает список в группу?
Я хочу создать группу из списка, возвращаемого задачей Celery, чтобы для каждого элемента в наборе результатов задачи в группу была добавлена одна задача. Вот простой пример кода для объяснения варианта использования.??? должен быть результатом ...
Django Celery Logging Лучшие практики
Я пытаюсь заставить лесозаготовку работать сDjango, У меня есть настройки входа вsettings.py перейти на консоль (это прекрасно работает, так как я на хостингеHeroku). В верхней части каждого модуля у меня есть: import logging logger = ...
Запуск Celery: AttributeError: у объекта 'module' нет атрибута 'celery'
Я пытаюсь запустить рабочий сервер Celery из командной строки: celery -A tasks worker --loglevel=infoКод в tasks.py: import os os.environ[ 'DJANGO_SETTINGS_MODULE' ] = "proj.settings" from celery import task @task() def add_photos_task( lad_id ...
Чтение конфигурации Celery из файла свойств Python
У меня есть приложение, которое должно инициализировать Celery и другие вещи (например, база данных). Я хотел бы иметь INI-файл, который будет содержать конфигурацию приложений. Это должно быть передано приложению во ...
Как запустить сельдерей в качестве демона в производство?
я создал файл celeryd в / etc / defaults / из кода здесь: https://github.com/celery/celery/blob/3.0/extra/generic-init.d/celeryd [https://github.com/celery/celery/blob/3.0/extra/generic-init.d/celeryd] Теперь, когда я хочу запустить celeryd как ...
Как работник из сельдерея, потребляющий несколько очередей, решает, какой из них потреблять первым?
Я использую Celery для выполнения асинхронных фоновых задач с Redis в качестве бэкэнда. Меня интересует поведение работника из сельдерея в следующих ситуациях: Я работаю как рабочий демонceleryd, Этому работнику были назначены две очереди для ...