Результаты поиска по запросу "celery"
Сельдерей бить с методом задачи не работает
Я пытаюсь запустить метод сельдерея на методической задаче и не могу заставить что-либо работать должным образом. Вот пример настройки: from celery.contrib.methods import task_method from celery import Celery, current_app celery=celery('tasks', ...
Почему сельдерей добавляет тысячи очередей к rabbitmq, которые, похоже, сохраняются еще долго после завершения задачи?
Я использую сельдерей с бэкэндом rabbitmq. Он создает тысячи очередей с 0 или 1 элементами в них в rabbitmq, например: $ sudo rabbitmqctl list_queues Listing queues ... c2e9b4beefc7468ea7c9005009a57e1d 1 1162a89dd72840b19fbe9151c63a4eaa ...
Могу ли я использовать задачу отправки Java для сельдерея через rabbitmq?
Я просто касаюсь сельдерея и явы в течение 2 дней. :( Прямо сейчас у меня есть задача, чтобы Java-клиент отправлял задачу через rabbitmq. Сельдерей будет рабочим, чтобы справиться с задачей. Я знаю, что это легко для Python-> rabbitmq-> celery. ...
Как вы работаете с AWS Elastic Beanstalk?
Я запускаю приложение django на эластичном бобовом стебле aws. Я хотел бы запустить фоновое задание или рабочий, чтобы запустить сельдерей. Я не могу найти, если это возможно или нет. Если да, как это может быть достигнуто? Вот что я сейчас ...
Django Celery ConnectionError: Пропущено слишком много сердцебиений
ВопросКак я могу решитьConnectionError: Too many heartbeats missed из сельдерея? Пример ошибки[2013-02-11 15:15:38,513: ERROR/MainProcess] Error in timer: ConnectionError('Too many heartbeats missed', None, None, None, '') Traceback (most recent ...
Должны ли экземпляры объекта модели django передаваться сельдерею?
# models.py from django.db import models class Person(models.Model): first_name = models.CharField(max_length=30) last_name = models.CharField(max_length=30) text_blob = models.CharField(max_length=50000) # tasks.py import celery @celery.task def ...
Различают сельдерей, комбу, PyAMQP и RabbitMQ / ironMQ
Я хочу загрузить изображения на сервер S3, но перед загрузкой я хочу создать миниатюры 3 разных размеров, и я хочу, чтобы это делалось вне цикла запросов / ответов, поэтому я использую сельдерей. Я прочитал документы, вот что я понял. Пожалуйста, ...
Приоритет задачи в сельдерее с редисом
Я хотел бы реализовать распределенную систему выполнения работ с сельдереем. Учитывая, что rabbitMQ не поддерживает приоритеты, и мне очень нужна эта функция, я обратился к celery + redis. В моей ситуации задачи тесно связаны с оборудованием, ...
Запуск celeryd_multi с супервизором
Я работаю с djcelery и руководителем. Я управлял сельдереем с супервайзером, и все работало нормально, как только я понял, что мне нужно сменить его на мульти сельдерей, все сломалось. Если я запускаю celeryd_multi в терминале, он работает, но ...
Как проверять и отменять задания Celery по имени задания
Я использую Celery (3.0.15) с Redis в качестве брокера. Есть ли простой способ запросить количество задач с заданным именем, которые существуют в очереди Celery? И, как следствие, есть ли способ отменить все задачи с заданным именем, ...