Помеченные вопросы [celery]

0 голосов
0 ответы
Невозможно передать сообщение с помощью сельдерея
Я пытаюсь использовать встроенную поддержку сельдерея для широковещательной маршрутизации, используя Broadcast и используя rabbitmq в качестве б...
спросил 3 месяца назад
0 голосов
1 ответы
Удаление элементов из celery_beat не удаляет их из расписания базы данных
Я использую django-celery-beat в приложении django (это сохраняет расписание в базе данных вместо локального файла). Я настроил свое расписание...
спросил 3 месяца назад
0 голосов
0 ответы
celery: почему это полезно, когда я удаляю пункт «search localdomain» в /etc/resolv.conf
когда я использую "celery -A task worker -l info", то рабочий узел происходит следующим образом: [2019-04-26 20:27:00,290: ERROR/MainProcess...
спросил 3 месяца назад
0 голосов
0 ответы
Начало работы с Celery от CouchDB _changes
CouchDB может создавать «уведомления» с помощью опроса конечной точки _changes . Я бы хотел, чтобы Celery получил задание из _changes. Я согл...
спросил 3 месяца назад
0 голосов
0 ответы
Невозможно запустить Django Celery после следующей документации
Я пытаюсь внедрить сельдерей в текущий проект django 2. Я использую Django 2.13 и сельдерея 4.3. Вот код в init .py: import os from celery i...
спросил 3 месяца назад
0 голосов
0 ответы
Добавление очередей в Rabbitmq и рабочих в очереди в сельдерее
Попытка выполнить около 66 сценариев Python, которые выполняют некоторые задачи по обработке данных. Выполнение трех сценариев занимает очень мн...
спросил 3 месяца назад
0 голосов
1 ответы
Почему у Celery разное поведение в двух вариантах запуска рабочего?
Я добавил работника из сельдерея в пакет app: proj ├── app │   ├── worker.py │   └── server.py └── db ├── db.sql ├── check_db_health.p...
спросил 3 месяца назад
0 голосов
0 ответы
Flask - jsonify результаты задачи Celery
У меня длинное задание из сельдерея: @celery.task(queue='cache') def cache_user_tracks(user_id): # generator - yields external api calls...
спросил 3 месяца назад
0 голосов
1 ответы
celery: выводит состояние каждой задачи в группе, которая начинается с apply_async
Я пытаюсь распечатать состояние 4 удаленных задач, получая информацию от каждого AsyncResult в группе. Пока я могу печатать статус, но не имя...
спросил 3 месяца назад
0 голосов
0 ответы
Сельдерей: модуль не найден
Я использую Открытый семантический поиск (OSS) и хотел бы отслеживать его процессы с помощью инструмента для работы с цветами , Работники, в к...
спросил 3 месяца назад
0 голосов
1 ответы
Как я могу изменить название задачи, которую Celery отправляет на сервер?
Я построил систему очередей с использованием Celery, которая принимает веб-запросы и выполняет некоторые задачи для обработки этих запросов. Я и...
спросил 3 месяца назад
0 голосов
0 ответы
Расширение использования уникальной очереди для каждой задачи с бэкэндом Redis
Я понял, что бэкэнд Redis для сельдерея хранит каждый запрос задачи в списке в очереди. Это делает удаление (прерывание) отложенной задачи ужасн...
спросил 3 месяца назад
0 голосов
0 ответы
Операторы воздушного потока on_kill и тайм-аут сельдерея
Мы бы хотели установить время ожидания сельдерея на 2 часа с параметром visibility_timeout. наш dag отправляет задания внешним API для запуска в...
спросил 3 месяца назад
0 голосов
1 ответы
Сельдерей Принимает больше задач, чем рабочий параллелизм
Я выполняю несколько долго выполняющихся задач в выделенной очереди. Так что нет коротких временных задач. В настоящее время, когда я запускаю м...
спросил 3 месяца назад
0 голосов
1 ответы
Невозможно импортировать имя приложения при использовании Celery во Flask
Я пишу простое приложение Flask, которое использует Celery для выполнения фоновой задачи, но когда я пытаюсь запустить приложение на терминале,...
спросил 3 месяца назад
0 голосов
2 ответы
Не удалось запустить рабочий процесс Celery с помощью Django в debug = False (production)
Это задача Celery для отправки электронной почты, забавно то, что все работает правильно в режиме DEBUG = True, но не работает в производственно...
спросил 3 месяца назад
0 голосов
1 ответы
Результаты запроса из сельдерея результатов Backend MYSQL
Какой самый простой способ запросить все результаты из обработчика результатов в сельдерее? Я использую хранилище данных MySQL в качестве бэкэнд...
спросил 3 месяца назад
2 голосов
2 ответы
Не удается увидеть выходные сообщения задач, выполненных в комбинации celery-rabbitMQ
Я испытываю комбинации сельдерея и rabbitMQ для планирования асинхронных задач. Ниже приведен пример программы, которую я пробовал в Pycharm IDE...
спросил 3 месяца назад
0 голосов
1 ответы
Как рабочий (поток) может зарезервировать дисковое пространство и сообщить о резервировании другим работникам
Я пытаюсь настроить класс автоматического масштабирования, который будет проверять ресурс диска, чтобы определить, может ли работник безопасно р...
спросил 3 месяца назад
0 голосов
0 ответы
преобразовать значение rule в значение cron в python для поддержки ритма сельдерея
Здравствуйте, я пытаюсь внедрить ритм сельдерея для планирования услуг, но наш пользовательский интерфейс предназначен для отправки данных в фор...
спросил 3 месяца назад
0 голосов
1 ответы
Невозможно запустить работников сельдерея (Приложение Flask)
Я пробую сельдерей с помощью Python Flask. celery_example.py from __future__ import absolute_import, unicode_literals from flask import Fla...
спросил 4 месяца назад
0 голосов
0 ответы
Можно ли вызвать задачу в цепочке с параметризацией опции * max_retries *?
Мне нужно выполнить одну и ту же задачу в разных цепочках с разным поведением. Для цепочки A я хочу ограничить количество перезапусков, поэтому...
спросил 4 месяца назад
1 голосов
1 ответы
Задача сельдерея, вызывающая себя после того, как задача успешно выполняется без сельдерея
Я хочу вызывать свою задачу сельдерея иногда, как каждые 30 минут после выполнения текущей задачи, но иногда задача занимает больше времени, чем...
спросил 4 месяца назад
1 голосов
0 ответы
Что означает переменная CELERY_TIMEZONE в файле settings.py проекта Django?
Я знаю, что USE_TZ=True сохраняет все объекты datetime в формате UTC в базе данных. В этом случае, когда запланировано выполнение задачи через р...
спросил 4 месяца назад
0 голосов
1 ответы
Необработанное исключение в сельдерее замораживает рабочих
Я запускаю сельдерей в докере через бэкэнд Redis. У меня есть контейнер с сельдереем контейнер для сельдерея контейнер redis Рабочий...
спросил 4 месяца назад