Вопросы по теме 'celery'
Задача Celery, которая общается с Twitter
Каков правильный подход при написании задач сельдерея, которые взаимодействуют со службой, которая имеет ограничения по скорости и иногда отсутствует (не отвечает) в течение длительного периода времени?
Должен ли я использовать повтор задачи? Что...
296 просмотров
schedule
29.10.2022
Повторение задач, отправленных «send_task» в сельдерее
мы используем сельдерей с серверной частью RabbitMQ, и некоторые из наших серверов зависают с ошибкой: «[Errno 113] Нет маршрута к хосту» (что может быть результатом того, что половина наших серверов находится в США, а половина в Европе).
Мне нужно...
1544 просмотров
schedule
04.03.2024
Как мне реализовать обратный вызов для набора задач в сельдерее
Вопрос
Я использую celery для запуска наборов задач, которые выглядят так:
Я выполняю пакет задач, которые можно запускать параллельно, количество задач в этом пакете варьируется от десятков до пары тысяч.
Я объединяю результаты этих задач...
3042 просмотров
schedule
09.02.2024
Celerybeat не работает должным образом
Я создаю какой-то проект с бутылкой, и мне нужно, чтобы он периодически запускал определенные запланированные действия.
Я решил использовать rabbitmq + celery, так как это казалось наиболее надежным и полным решением для программного управления...
2992 просмотров
schedule
22.04.2024
Celeryd не казнит моих рабочих
Я пытаюсь демонизировать свои задачи в сельдерее, я тестировал без демонизации, и он работает очень хорошо.
Но я не могу демонизировать, как сказано в руководстве ( http://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing ) У...
186 просмотров
schedule
09.10.2023
Celery: объединение задач с несколькими аргументами
Документация по сельдерею говорит мне, что если несколько задач объединены в цепочку, результат первой задачи будет первым аргументом следующей. Моя проблема в том, что я не могу заставить его работать, когда у меня есть задача, которая возвращает...
6327 просмотров
schedule
04.04.2024
Почему Celery НЕ выдает исключение, когда основная задача выдает его
Сельдерей, похоже, не обрабатывает исключения должным образом.
Если у меня есть задача:
def errorTest():
raise Exception()
а потом я звоню
r = errorTest.delay()
In [8]: r.result
In [9]: r.state
Out[9]: 'PENDING'
И так будет...
20751 просмотров
schedule
19.10.2023
Celerybeat иногда пропускает задачи
У нас есть установка Celery (+Celerybeat) с серверной частью RabbitMQ, выполняющей запланированные и незапланированные задачи. Я заметил, что иногда пропускаю/отбрасываю выполнение запланированной задачи. Все продолжает работать правильно, и задача...
803 просмотров
schedule
04.09.2022
Задачи Celery не запускаются в отладчике PyCharm
Я использую PyCharm и заметил, что когда я подключаю отладчик к рабочему процессу сельдерея, мои задачи не выполняются, и эта ошибка регистрируется в консоли:
Traceback (most recent call last):
File "<string>", line 1, in <module>...
5057 просмотров
schedule
29.03.2024
Сельдерей против Ipython параллельно
Я просмотрел документацию по обоим, но не уверен, что лучший выбор для данного приложения. Я внимательно рассмотрел сельдерей, поэтому пример будет приведен в этих терминах.
Мой вариант использования похож на этот >вопрос : каждый рабочий процесс...
760 просмотров
schedule
24.02.2024
Получить длину очереди с помощью Celery (RabbitMQ, Django)
Я использую Celery в проекте django, мой брокер RabbitMQ, и я хочу получить длину очередей. Я просмотрел код Celery, но не нашел инструмента для этого. Я обнаружил эту проблему в stackoverflow ( Проверить размер очереди RabbitMQ от клиента ), но Я...
6354 просмотров
schedule
09.09.2022
Измерение времени выполнения задачи Celery
Я преобразовал автономное пакетное задание, чтобы использовать сельдерей для отправки работы, которую необходимо выполнить. Я использую RabbitMQ. Все выполняется на одной машине, и никакие другие процессы не используют экземпляр RabbitMQ. Мой...
8476 просмотров
schedule
29.06.2022
Задачи Celery с невыбираемыми аргументами
Я пытаюсь внедрить систему очередей сообщений для отправки операций в API AdWords.
class Call(object):
@celery.task(filter=task_method)
def MUTATE(self, operations):
assert hasattr(self, '__throwaway_service')
with...
1216 просмотров
schedule
20.04.2024
django — разница между сигналами и сельдереем
Это может быть хромой вопрос, но я действительно запутался с этими двумя. Я знаю, что signals используются для выполнения какой-то задачи, когда что-то случилось. Но как насчет сельдерея? В документации сказано:
Celery — это асинхронная...
1483 просмотров
schedule
28.08.2022
Реализация локальных множественных отложенных обратных вызовов в стиле Twisted в Celery
Я новичок в использовании Celery, и мне было интересно, как можно реализовать несколько отложенных обратных вызовов типа TWSITED в Celery.
МОЙ TWISTED CODE использует перспективного брокера и выглядит следующим образом. У меня есть обработчик...
685 просмотров
schedule
07.10.2023
Celery worker и аргументы командной строки
Я реорганизую свой код, чтобы использовать celery worker.
Раньше я использовал argparse для передачи аргументов командной строки.
e.g.
if __name__ == "__main__":
parser = argparse.ArgumentParser(description='Node')...
11601 просмотров
schedule
19.01.2024
Автоматизация перекодирования в Amazon Elastic Transcoder
Можно ли автоматизировать работу по перекодированию в Amazon Elastic Transcoder? Я использую фреймворк Django. Если да, то как мне начать. Я с такими темами не сталкивался, поэтому пришлось спросить здесь. Будем очень признательны за вашу помощь и...
3264 просмотров
schedule
18.08.2022
Celery & Cloudamqp на Heroku выдает ошибку: [Errno 111] В соединении отказано
У меня есть приложение Django, и оно использует Celery для асинхронных задач. Кроме того, я использую RabbitMQ локально, но на Heroku я пытаюсь установить плагин CloudAMQP. Приложение запускается без каких-либо ошибок, однако любая задача,...
937 просмотров
schedule
04.10.2023
как не вызывать метод при возникновении исключения в сельдерее?
У меня есть пример кода сельдерея:
from __future__ import absolute_import
from proj.celery import app
@app.task
def add(x, y):
try:
return x + y
except Exception,e:
raise
@app.task
def mul(x, y):
try:
return x...
55 просмотров
schedule
28.06.2022
Доступ запрещен для пользователя rabbitmq и celery
Я создаю виртуальный хост:
rabbitmqctl add_vhost test
Затем пользователь:
rabbitmqctl add_user user 123456
Затем я получаю разрешения для этого пользователя:
rabbitmqctl set_permissions -p test user "test" "test" "test"
Я...
21716 просмотров
schedule
29.11.2023
