22
ответа
Как вернуть правильный json из результата sql alchemy с подключением? [Дубликат]
В настоящее время я создаю приложение, состоящее из API (который я создаю с помощью Connexion), celery и sql alchemy. Вызов API запускает задачи celery, которые запрашивают базу данных и возвращают ...
вопрос задан: 10 April 2016 02:09
9
ответов
колба сельдерея получить задание статус задачи в реальном времени [дубликат]
все, что я использую флягу, и я ищу способ отображения в конечном итоге в таблице статуса работы сельдерея. Я придумал решение, которое работает только наполовину. У меня есть mongodb работает как моя ...
вопрос задан: 27 January 2012 15:49
6
ответов
Возвратите список импортированных модулей Python, используемых в сценарии?
Я пишу программу, которая категоризирует список файлов Python, которыми модулями они импортируют. Как таковой я должен просканировать набор .py возврата рекламы файлов, список которого модули они импортируют. Как...
вопрос задан: 3 April 2010 21:15
4
ответа
Ansible 2.4: запуск сельдерея 3.1 в качестве демона, в то время как другая задача выполняется [дублировать]
Предыстория Я использую Ansible для создания бродячего бокса. Как часть этого обеспечения, мне нужно выполнить скрипт python во время работы сельдерея. У меня проблемы с получением Ansible для сохранения сельдерея ...
вопрос задан: 22 April 2015 19:04
4
ответа
Убедитесь, что Redis не работает [дубликат]
Я использую сельдерей с Django. Если Redis не работает, сельдерей вешает бесконечно, это известная ошибка в сельдере. Конечно, я не хочу зависать, и пользователь ждет, но предлагает «резервное» решение, поэтому мне нужно ...
вопрос задан: 12 October 2012 11:59
4
ответа
Как я могу запланировать Задачу выполниться в определенное время с помощью сельдерея?
Я изучил PeriodicTask, но примеры только покрывают то, чтобы заставлять его повториться. Я ищу что-то больше как способность крона сказать, "выполняют эту задачу каждый понедельник в 1:00".
вопрос задан: 2 January 2010 03:37
3
ответа
Отправлять сообщения журнала от всех задач сельдерея в один файл
Мне интересно, как настроить более конкретную систему ведения журнала. Все мои задачи используют logger = logging.getLogger (__ name__) в качестве общемодульного регистратора. Я хочу, чтобы сельдерей регистрировался в "celeryd.log", а мои задачи - в ".
вопрос задан: 9 October 2014 17:37
3
ответа
Есть ли максимальный размер для объектов, возвращаемых Задачами Сельдерея? [Дубликат]
Я использую Celery для запуска фоновых задач для приложения Flask. Сельдерей использует Redis как своего брокера, так и его результаты. Фоновая задача возвращает довольно большой (~ 100 МБ) пользовательский объект. Однако, ...
вопрос задан: 9 April 2011 17:04
3
ответа
Требуется ли этому веб-приложению очередь задач?
Справочная информация У меня есть веб-приложение, которое создает изображение на основе пользовательского ввода.
Создание изображения может занять до пары секунд. Проблема Если я разрешаю потоку сервера, который обрабатывает запрос / ...
вопрос задан: 26 August 2010 18:28
2
ответа
Сигнал Джанго на основе значения поля даты и времени
Я борюсь со следующим. Я пытаюсь создать собственный сигнал, который будет срабатывать, когда текущее время будет равно значению notify_on DateTimeField моей модели. Что-то вроде этого: ...
вопрос задан: 26 March 2019 23:16
2
ответа
Получение логов сельдерея по умолчанию
Я не могу получить доступ к журналам по умолчанию сельдерея без использования терминала и с использованием кода Python. Можно получить с терминалом, используя -f. хочу получить логи в файле, используя скрипт Python и ...
вопрос задан: 22 February 2019 11:38
2
ответа
Как ждать результатов от сельдерея в Джанго
У меня есть задача сельдерея, которая отправляет данные в другой сервис. Я добавил задачу сельдерея send_inventory_request в представление на основе класса RequestSupplyStock. когда я делаю пост, я должен сначала получить результаты ...
вопрос задан: 18 January 2019 09:03
2
ответа
Как настроить главный узел воздушного потока
Я пытаюсь изменить существующий кластер воздушного потока и сельдерея, чтобы сделать планировщик выделенным главным узлом, который не выполняет задания. (В настоящее время все узлы работают как рабочие; я хочу предотвратить ...
вопрос задан: 17 January 2019 01:40
2
ответа
Увеличивает ли поле в атомарном MySQL?
Я создаю веб-сайт, на котором я хотел бы увеличить счетчик в стандартной таблице MyISAM. Упрощенный пример: UPDATE голосов SET num = num + 1; Я переключил команду из crontab на периодическую задачу, и она работает хорошо, но просто вызывает метод модели.
вопрос задан: 16 August 2017 16:00
2
ответа
сельдерей-django не может найти настройки
У меня есть проект Django, который использует Сельдерей для выполнения асинхронных задач. Я делаю свою разработку на машине Windows XP. Запуск моего сервера Django (python manage.py runserver 80) хорошо работает, но...
вопрос задан: 25 February 2013 15:20
2
ответа
Rabbitmq или Gearman - выбор [закрытой] очереди заданий
На работе мы должны создать сервер заданий для вещей как отправка электронных писем, создание PDFs, уплотнение некоторых данных, и т.д. Очевидно, мы хотели бы основываться на своего рода универсальной системе массового обслуживания. Я знаком...
вопрос задан: 29 March 2011 23:03
1
ответ
Celery: выполнение нескольких асинхронных подзадач приводит к тому, что & ldquo; никогда не вызывать results.get () & rdquo; ошибка
Я пытаюсь использовать Celery для запуска нескольких асинхронных заданий, и хотя функции ведут себя так, как должны, я продолжаю получать следующую ошибку: RuntimeWarning: никогда не вызывать result.get () в пределах ...
вопрос задан: 19 March 2019 15:36
1
ответ
Логика постановки задачи на неудачу сельдерея (RabbitMQ)
У меня есть следующие настройки: версия сельдерея = 4.2.1 task_reject_on_worker_lost = True task_acks_late = True Я пытаюсь получить сообщение для маршрутизации в "QueueA" первоначально, и если работник сельдерея это ...
вопрос задан: 5 March 2019 19:01
1
ответ
Когда начинается отсчет времени для задания Celery?
В настоящее время я работаю с моим приложением django, у меня возникают проблемы с Celery, где задача иногда занимает 1-2 секунды, но иногда занимает 15-25 секунд. Мое приложение - это приложение, связанное с чатботом, поэтому оно должно ...
вопрос задан: 3 March 2019 16:23
1
ответ
Ошибка декодирования Unicode в Celery при попытке прочитать результаты из очереди Redis
Попытка выполнить несколько простых задач через сельдерей. Заголовок рабочего файла выглядит следующим образом: импорт сельдерея. Сельдерей, группа со временем импорта. Sleep Celery = Celery ('workerprocess', broker = 'redis: // ...
вопрос задан: 22 January 2019 01:40
1
ответ
Задачи Celerybeat получают ту же информацию, даже если она изменилась. (возможно кэширование) Как я могу отключить это
У меня есть задание в ритме сельдерея, которое запускается каждые 2 минуты. Это берет цикл if, основанный на существовании объекта БД self.dbObject = Patch.find_by_status ('READY'), я включаю рабочий и ...
вопрос задан: 18 January 2019 13:29
1
ответ
NOAUTH Требуется аутентификация. Настройки Redis в Docker Compose для Django
Я продолжаю получать сообщение об ошибке: redis.exceptions.ResponseError: NOAUTH Требуется аутентификация .. (я использую сельдерей для выполнения фоновых задач). Мой settings.py выглядит так: ...
вопрос задан: 17 January 2019 15:54
1
ответ
Невозможно отправить журналы задач Celery в Google Cloud (стековый драйвер)
Я пытаюсь протолкнуть журналы задач сельдерея в GCP, используя их Logging API. Я использую google.cloud.logging.handlers.CloudLoggingHandler для того же. Вот как я это делаю: settings.py из google.cloud ...
вопрос задан: 16 January 2019 14:37
1
ответ
Как отправить электронное письмо для сброса пароля Django с помощью Celery (без стороннего пакета)?
Прежде всего, я знаю, что на этот вопрос ранее уже был дан ответ, который использует сторонний пакет django-celery-email, но я пытаюсь выяснить, как сделать такую работу, не передавая ни на что ...
вопрос задан: 15 January 2019 15:32
1
ответ
Почему работник сельдерея дает & ldquo; OSError: Socket closed & rdquo;
Мой работник сельдерея, который работает с rabbitMQ, продолжает давать мне ошибку сокета - см. Ниже - после работы в течение нескольких минут. Я хотел бы знать, что может быть основной причиной проблемы? Я думал так ...
вопрос задан: 13 July 2018 17:55
1
ответ
Глобально доступный объект через всех рабочих Celery / кэш памяти в Django
У меня есть довольно стандартная установка Django+Rabbitmq+Celery с 1 задачей Сельдерея и 5 рабочими. Задача загружает то же (я упрощаю немного), большой файл (~100MB) асинхронно ко многим удаленным ПК. Все...
вопрос задан: 23 May 2017 12:02
1
ответ
RabbitMQ / Сельдерей с Django держится, задерживаться/подготавливать/и т.д. - Никакая полезная информация о журнале
Таким образом, я просто устанавливаю сельдерей и rabbitmq, создал моего пользователя, установите vhost, отобразил пользователя на vhost и выполнил демона сельдерея успешно (или таким образом, я принимаю) (queuetest) corky@corky-server: ~/projects/...
вопрос задан: 19 December 2015 11:35
1
ответ
Как запустить работника Celery из скрипта / модуля __main__?
Я определил приложение Celery в модуле, и теперь я хочу запустить рабочий из того же модуля в его __main__, т.е. запустить модуль с python -m вместо celery из командной строки. Я ...
вопрос задан: 30 April 2014 13:13
1
ответ
Выполнение Django-сельдерея в производстве
Я создал веб-приложение Django и некоторые Django-поршневые сервисы. Используя веб-интерфейс пользователь отправляет некоторые данные, которые ОТПРАВЛЯЮТСЯ на веб-сервис и что веб-сервис в свою очередь использует Django-сельдерей для...
вопрос задан: 2 September 2013 23:56
1
ответ
Как проверить статус задачи в Celery?
Как проверить, запущена ли задача в celery (конкретно, я использую celery-django)? Я читал документацию, гуглил, но не вижу вызова типа: my_example_task.state() == ...
вопрос задан: 27 January 2012 13:49