1
ответ

Celery с Amazon SQS

Я хочу использовать Amazon SQS в качестве брокера, поддерживающего Celery. Существует реализация транспорта SQS для Kombu, от которого зависит Celery. Однако документации для его использования недостаточно, поэтому я не могу ...
вопрос задан: 7 November 2011 22:53
1
ответ

Разработка с помощью Django + Celery без запуска `celeryd`?

В процессе разработки довольно сложно запускать celeryd, а также сервер разработки Django. Можно ли, например, попросить сельдерей синхронно запускать задачи во время разработки? Или ...
вопрос задан: 6 October 2010 15:54
1
ответ

Прерывание выполняющейся задачи в Celery внутри django

Я хотел бы иметь возможность прервать выполнение задачи, выполняющейся из очереди Celery (с использованием rabbitMQ). Я вызываю задачу, используя task_id = AsyncBoot.apply_async (args = [name], name = name, connect_timeout = 3), где ...
вопрос задан: 26 August 2010 15:11
1
ответ

Как я задерживаю задачу с помощью Сельдерея?

Не говоря о методе задержки. Я хочу смочь получить задачу, учитывая он - task_id и изменение, это - ETA на лету, прежде чем это будет выполнено. На данный момент я должен отменить его и перенести тот...
вопрос задан: 28 July 2010 21:03
1
ответ

Сельдерей - Получает идентификатор задачи для текущей задачи

Как я могу получить значение task_id для задачи из задачи? Вот мой код: от celery.decorators импортируют задачу из кэша импорта django.core.cache @task определение do_job (путь): "Работает...
вопрос задан: 22 July 2010 08:12
1
ответ

AMQP по сравнению с Websphere MQ

Мы работаем над приложением, которое поддерживает AMQP для организации очередей. Некоторые наши клиенты используют Websphere MQ. Я просто размышляю над высоким уровнем, насколько взаимозаменяемый эти два протокола с точки зрения...
вопрос задан: 30 June 2010 17:52
1
ответ

удалите Задачу / PeriodicTask в сельдерее

Как я могу удалить регулярную Задачу или PeriodicTask в сельдерее?
вопрос задан: 1 April 2010 00:30
1
ответ

Действительно ли возможно выполнить автоматически сельдерей при запуске?

У меня есть сервер Python на основе django и сельдерея. Каждый раз компьютерные перезапуски, apache2 запускается так, мой сервер работает, НО я должен перезапустить сельдерей вручную (идущий в мой каталог проекта и...
вопрос задан: 18 February 2010 20:57
1
ответ

Как я могу настроить Сельдерей, чтобы вызвать таможенную функцию инициализации прежде, чем управлять моими задачами?

У меня есть проект Джанго, и я пытаюсь использовать Сельдерей, чтобы представить задачи для фоновой обработки (http://ask.github.com/celery/introduction.html). Сельдерей объединяется хорошо с Джанго, и я был в состоянии...
вопрос задан: 25 January 2010 04:07
0
ответов

Как долго сельдерей проверяет предыдущие не выполненные задачи

Я обновил расписание для одной из моих задач с сельдереем и изменил ее на запуск по вторникам в 1:00 по UTC. Добавил эти изменения и перезапустил сельдерей после 12:00 UTC во вторник. Я ожидал, что задача запустится ...
вопрос задан: 27 March 2019 07:57
0
ответов

Работа с сельдереем сохраняет данные неправильно или сильно

У меня есть работа с сельдереем, чтобы получить данные о крипто-ставках с сайта coinmarketcap.com Если задание запускалось несколько раз, у меня в базе данных не было 100 результатов, я всегда получал 101-108 записей. Почему так? ...
вопрос задан: 26 March 2019 16:10
0
ответов

Комбу / Сельдерей Издатель Подписчик

У меня есть очень простое приложение Django. В настоящее время приложение использует очередь издателя RabbitMQ (cloudamqp). Вот код для потребителя: из Kombu импортировать Connection, Exchange, Queue ...
вопрос задан: 24 March 2019 00:52
0
ответов

Как использовать группу и цепочки сельдерея для достижения сочетания синхронных и асинхронных задач?

Я хочу создать задачу A сельдерея, которая сама создает задачи, скажем X, Y, Z и т. Д., И они должны выполняться асинхронно. Задача A должна дождаться завершения задач X, Y, Z и возврата результатов. ...
вопрос задан: 19 March 2019 09:37
0
ответов

Django & amp; Сельдерей, задачи не активируются при использовании venv

Я начал использовать Celery в своем проекте Django, Redis - брокер. Все хорошо, когда я устанавливаю сельдерей по всему миру. Но когда я устанавливаю Celery в виртуальную среду, все задачи как бы зависают. ...
вопрос задан: 18 March 2019 14:37
0
ответов

Celery 4 с RabbitMQ очень медленно буферизует задачи ETA при запуске

Контекст Я недавно начал пытаться обновить Celery с 3.1.25 до 4.2.1. Мы используем Python 2.7.6, бэкэнд RabbitMQ (3.6) и драйвер pyamqp. Мы запускаем сельдерей с отключенными ящичками для ...
вопрос задан: 10 March 2019 01:15
0
ответов

Как мне изящно закрыть цветок сельдерея?

Когда я отправляю SIGTERM, иногда цветок умирает с этим исключением & amp; его база данных не содержит последних задач. Файл "/home/devil/envs/celery/lib/python3.6/ site-packages / flower / app.py", ...
вопрос задан: 5 March 2019 02:28
0
ответов

Как переместить каждый сетевой вызов на сельдерее как задание для работника

При написании этого вопроса, нужно знать, как добиться того же, что упоминалось в теме, описание следующим образом, у меня есть класс, который имеет различные функции, каждая функция имеет некоторые разные ссылки, которые ...
вопрос задан: 3 March 2019 13:44
0
ответов

цветок сельдерея не показывает ранее выполненные задачи после перезапуска

Я использую сельдерей с Джанго и использую цветок для проверки задач. Я использую rabbitmq в качестве брокера. Все работает нормально, но после перезапуска цветка ранее перечисленные состояния задач теряются, и я вижу 0 ...
вопрос задан: 22 February 2019 11:31
0
ответов

Как вызвать asyncio def из представления Django (и сделать его неблокирующим)?

Как я могу запустить асинхронную функцию из представления Django? Я пытаюсь следующее: def tools (request): ids = get_ids () print (ids) возвращает render (request, 'strava_tools / tools.html') def ...
вопрос задан: 18 January 2019 20:56
0
ответов

конвертировать файл сельдерея в бинарный файл, используя pyinstaller

Есть ли способ, которым мы можем преобразовать файл задач сельдерея с помощью pyinstaller и запустить его. я использую pyinstaller --onefile taskfile.py Но как мне запустить это с командой сельдерея работника
вопрос задан: 18 January 2019 08:14
0
ответов

django celery AsyncResult AttributeError: у объекта 'DisabledBackend' нет атрибута '_get_task_meta_for'

Я использую django celery (4.2), и я добавлю некоторые задачи из моего представления django, также я хочу получить асинхронный результат задачи в отдельном процессе, но когда я пытаюсь получить результат, я получил некоторые ошибки. Мой ...
вопрос задан: 15 January 2019 18:51
0
ответов

Является ли Celery столь же эффективным в локальной системе, как многопроцессорность python?

У меня небольшие проблемы с принятием решения о том, что использовать многопроцессорность python, сельдерей или pp для моего приложения . Мое приложение очень загружено ЦП, но в настоящее время использует только один ЦП, поэтому мне нужно распространить
вопрос задан: 20 November 2018 05:30
0
ответов

Повтор выполнения задач с помощью Django-Celery - Django / Celery

У меня проблемы с повторным выполнением задач , вот как выглядит тестовая задача из задачи импорта celery.decorators @task () def add (x, y): if not x or not y: raise Exception ("test error") ...
вопрос задан: 17 October 2018 02:08
0
ответов

Повторить утерянные или неудачные задачи (Celery, Django и RabbitMQ)

Есть ли способ определить, потеряна ли какая-либо задача, и повторить попытку? Я думаю, что причиной потери может быть ошибка диспетчера или сбой рабочего потока. Я планировал повторить их, но не знаю, как ...
вопрос задан: 19 March 2018 04:21
0
ответов

Выполнение «уникальных» задач с сельдереем

Я использую сельдерей для обновления RSS-каналов на моем сайте агрегации новостей. Я использую одну @task для каждого канала, и, похоже, все работает нормально. Есть деталь, с которой я не уверен, что с ней справлюсь: все каналы ...
вопрос задан: 16 October 2017 18:24
0
ответов

Celery - расписание периодических задач, начинающихся в определенное время

Какой лучший способ запланировать периодическую задачу, начинающуюся в определенное время? (Я не использую cron для этого, учитывая, что мне нужно запланировать около сотни удаленных rsyncs, где я вычисляю ...
вопрос задан: 16 September 2017 11:23
0
ответов

Ошибка OSE: dlopen (libSystem.dylib, 6): изображение не найдено

Только что обновил мой Mac до El Capitan 10.11. Я пытаюсь запустить Django 1.6 с Celery 3.1 и сейчас получаю эту ошибку: необработанное исключение в потоке, запущенном ...
вопрос задан: 23 May 2017 12:34
0
ответов

django celery: как программно настроить задачу на выполнение с определенным интервалом

Я обнаружил, что могу настроить выполнение задачи с определенным интервалом в определенное время отсюда, но это было сделано только во время объявления задачи. Как настроить периодическое динамическое выполнение задачи?
вопрос задан: 23 May 2017 12:31
0
ответов

Django Celery: выполнение только одного экземпляра длительного процесса

У меня есть длительный процесс, который должен запускаться каждые пять минут, но более одного экземпляра процессов никогда не должны запускаться одновременно. Обычно процесс не должен выполняться дольше пяти минут, но я ...
вопрос задан: 23 May 2017 12:30
0
ответов

Как убедиться, что задача Celery предотвращает перекрытие выполнения задач Celery

Как предотвратить выполнение периодической задачи Celery до завершения предыдущего выполнения? У меня есть кластер серверов, связанных с общим сервером базы данных, выполняющих задачи Celery, и я...
вопрос задан: 23 May 2017 12:26