Описание тега celerybeat

Описание тега Вопросы с тегом
The Celery periodic task scheduler
0 ответов

Сельдерей - Индивидуальный набор результатов каждой группы в цепочке

У меня есть периодическое задание, которое дает мне вновь добавленные пользователи говорят каждые 100 секунд. Я хочу выполнить две разные задачи в списке пользователей, полностью независимых друг от друга. Я настроил две очереди, используя celery_ro…
10 окт '17 в 17:58
0 ответов

Как загрузить задачи в редис-сервер

Я создал файл сельдерея и файл задачи, но когда я запускаю сервер Redis, я не вижу загрузки своих задач. ниже мой celery.py from __future__ import absolute_import, unicode_literals import os from celery import Celery from celery.schedules import cro…
23 ноя '18 в 03:53
1 ответ

Несколько экземпляров сельдерея для автоматического масштабирования приложения django на эластичном стебле

Я пытаюсь найти лучший способ структурировать приложение Django, которое использует Celery для обработки асинхронных и запланированных задач в автоматическом масштабировании среды AWS ElasticBeanstalk. До сих пор я использовал только один экземпляр …
19 окт '16 в 00:48
1 ответ

Сельдерей: выполнить задание после определенного промежутка времени

Я хочу отправить электронное письмо своим пользователям ровно через 48 часов после их регистрации. Как мне добиться этого с помощью сельдерея? Если я создаю периодическое задание для отправки электронного письма, мне нужно будет выбрать конкретное в…
04 июн '14 в 10:48
1 ответ

Celerybeat график выполнения задачи несколько раз?

У меня есть задача Calculate_common_locations, которая запускается один раз через CELERYBEAT_SCHEDULE, Задача просто вызывает функцию в базе данных: @app.task def calculate_common_locations(): db.execute("SELECT * FROM calculate_centroids('b')") Это…
01 сен '14 в 01:44
3 ответа

Сельдерей бить - разные часовые пояса за задачу

Я использую сельдерей, чтобы наметить некоторые задачи. Я могу использовать параметр CELERY_TIMEZONE для планирования задач с помощью расписания crontab, и оно запускается в запланированное время в указанном часовом поясе. Но я хочу иметь возможност…
17 фев '14 в 11:02
1 ответ

Реализация таймера в Python

Общий обзор У меня есть проект Django среднего размера У меня есть куча префиксных деревьев в памяти (в отличие от БД) Узлы этих деревьев представляют сущности / объекты, на которые распространяется тайм-аут. Т.е. мне нужно тайм-аут этих узлов в раз…
05 июн '13 в 20:47
1 ответ

Как перезагрузить весь набор запросов из БД в Django?

Я бегу периодические задачи с сельдереем. Одна такая задача получает объекты из БД с помощью фильтра: pages = Page.objects.filter(active=True) изначально (до запуска самого сельдерея) в БД 10 таких объектов с active=True, При запуске задача выполняе…
13 фев '19 в 09:21
1 ответ

Как отключить повтор в сельдерее?

Я запускаю планировщик celerybeat каждые 15 минут, где мне нужно получить данные из API (ограничение скорости = 300 запросов / мин. Максимум) и сохранить результаты в базе данных. Я хотел бы получить URL-адреса параллельно с учетом ограничений скоро…
03 апр '18 в 12:00
1 ответ

Сельдерей с брокером Redis не может выполнить задачу Django

В эти дни я изучаю Python(2.7)/Django(1.5), разрабатывая свой собственный клон Reddit (на Ubuntu 14.04 LTS). Я пытаюсь включить в микс Celery(3.1) с Redis, используя его для периодического запуска алгоритма ранжирования в качестве задачи (на моей ло…
04 июн '15 в 14:09
1 ответ

Сельдерей мульти рабочих неожиданный порядок выполнения задачи

Я бегу сельдереем celery multi start --app=myapp fast_worker slow_worker -Q:fast_worker fast-queue -Q:slow_worker slow-queue -c:fast_worker 1 -c:slow_worker 1 --logfile=%n.log --pidfile=%n.pid И сельдерей celery beat -A myapp Задача: @task.periodic_…
02 май '17 в 13:30
1 ответ

Запустите Celery beat и работника одновременно в приложении FLASK

Я работаю над приложением FLASK с Celery. В нем я запускаю приложение, используя строку app.run(), Если я изменю это на следующее if __name__ == '__main__': application = current_app._get_current_object() worker = worker.worker(app=application) beat…
26 ноя '15 в 13:06
2 ответа

Django сельдерея позиционные аргументы ошибка планирования сельдерея

У меня проблемы с получением сельдерея для планирования моей функции из-за позиционных аргументов. читая документацию, я не понимаю, почему некоторые функции относятся к числу, а некоторые нет. Я попытался добавить в аргументы, такие же, как мои фун…
04 май '18 в 01:41
2 ответа

Сельдерей add_periodic_task блокирует работу Django в среде uwsgi

Я написал модуль, который динамически добавляет периодические задачи сельдерея на основе списка словарей в настройках проекта (импортируется через django.conf.settings). Я делаю это с помощью функции add_tasks который планирует функцию для вызова с …
13 ноя '17 в 11:32
0 ответов

Динамическое планирование с Celery Beat

Я создаю утилиту для тестирования, которая периодически запускает несколько тестов, некоторые из которых запланированы на ежедневную работу, некоторые ежечасно, некоторые еженедельно и т. Д. Я пытаюсь создать эту функцию на Celery Beat с брокером Ra…
03 окт '16 в 15:19
2 ответа

Сельдерей Бит на Amazon ECS

Я использую Amazon Web Services ECS (Elastic Container Service). Мое определение задачи содержит Application + Redis + Celery, и эти контейнеры определены в определении задачи. Автоматическое масштабирование установлено, поэтому на данный момент сущ…
17 янв '18 в 13:52
1 ответ

Как мне скоординировать группу демонов биений сельдерея?

У меня кластер из трех машин. Я хочу бежать celery beat на тех. У меня есть несколько связанных вопросов. У сельдерея есть это понятие постоянного планировщика. Пока мой график состоит только из записей в crontab и статически определяется CELERYBEAT…
22 ноя '12 в 08:16
9 ответов

Как динамически добавлять / удалять периодические задачи в Celery (celerybeat)

Если у меня есть функция, определенная следующим образом: def add(x,y): return x+y Есть ли способ динамически добавить эту функцию в качестве периодической задачи сельдерея и запустить его во время выполнения? Я хотел бы иметь возможность сделать чт…
17 апр '12 в 16:13
3 ответа

Django Celery Планирование команды manage.py

Мне нужно обновить индекс Solr по расписанию с помощью команды: (env)$ ./manage.py update_index Я просмотрел документы Celery и нашел информацию о расписании, но не смог найти способ запустить команду управления django по расписанию и внутри virtual…
15 июл '13 в 21:20
0 ответов

Данные Zoneinfo повреждены, как мне скомпилировать новые данные?

По сути, снова произошло то же самое, что и когда я задал этот вопрос. Однако на этот раз я не могу понять это снова. Я снова попробовал ответ Бурхана Халида и снова получаю те же ошибки. Я также попытался снова скопировать, вставив папку zoneinfo и…
19 июл '13 в 12:26