Вопросы по теме 'celery'
Как сохранить результат отложенного вызова с использованием сельдерея в представлении django?
Я следовал рекомендациям в http://celeryq.org/docs/django-celery/getting-started/first-steps-with-django.html и создал представление, которое вызывает мой тестовый метод в tasks.py:
import time
from celery.decorators import task
@task()
def...
1136 просмотров
schedule
04.07.2022
Сельдерей Джанго дает мне (13, «Отказано в доступе»)
Я использую сельдерей django в одном из своих проектов и получаю сообщение об ошибке (13, разрешение запрещено).
Смотрите ниже трассировку:
/usr/lib/python2.4/site-packages/django/core/handlers/base.py in get_response...
1538 просмотров
schedule
02.08.2022
Проблемы с подключением - Celery/Django
долгая ночь... не могу заставить мою вторую установку Celery/RabbitMQ работать.
шаг 1
sudo rabbitmq-server
работает: хорошо!
шаг 2
python manage.py celeryd -l info
ошибка: [2010-12-28 03:38:24,690: ERROR/MainProcess]...
6178 просмотров
schedule
27.03.2022
Почему он не может найти мой файл конфигурации сельдерея?
/home/myuser/mysite-env/lib/python2.6/site-packages/celery/loaders/default.py:53: NotConfigured: модуль celeryconfig.py не найден! Убедитесь, что он существует и доступен для Python. NotConfigured)
Я даже определил это в моем /etc/profile, а...
28056 просмотров
schedule
28.03.2022
Предоставляет ли опция django runserver возможность запуска других сценариев перезапуска?
Недавно я играл с джанго и сельдереем. Во время разработки раздражает тот факт, что мне приходится перезапускать демон celery каждый раз, когда я изменяю задачу. Когда я разрабатываю, мне обычно нравится использовать «manage.py runserver», который...
3003 просмотров
schedule
22.07.2023
Celery - запускайте разных воркеров на одном сервере
У меня есть 2 вида задач: Тип 1 - несколько небольших задач с высоким приоритетом. Type2 - много тяжелых задач с более низким приоритетом.
Изначально у меня была простая конфигурация с маршрутизацией по умолчанию, ключи маршрутизации не...
23588 просмотров
schedule
11.06.2024
Отправлять сообщения журнала от всех задач сельдерея в один файл
Мне интересно, как настроить более конкретную систему ведения журнала. Все мои задачи используют
logger = logging.getLogger(__name__)
как общемодульный регистратор.
Я хочу, чтобы сельдерей регистрировался в «celeryd.log», а мои задачи - в...
61727 просмотров
schedule
13.04.2023
Повторите попытку с задачами обратного вызова celery Http
Я просматриваю задачи обратного вызова http - http://celeryproject.org/docs/userguide/remote-tasks.html в сельдерее. Они работают достаточно хорошо, когда удаленная конечная точка доступна, но когда она недоступна, я бы хотел, чтобы она повторила...
814 просмотров
schedule
18.06.2023
Как настроить TASK_SERIALIZER с помощью django-celery
Я использую django-celery и хочу установить TASK_SERIALIZER в JSON вместо рассола.
Я могу сделать это для каждого метода, изменив декораторы задач с
@task
to
@task(serializer="json")
Но я хотел бы сделать это глобально....
7450 просмотров
schedule
28.02.2024
Celery для Map-Reduce или другие альтернативы в Python?
У меня есть дорогостоящие задания, которые очень подходят для запуска в рамках модели map-and-reduce (короче говоря, это объединение нескольких сотен рейтингов, которые предварительно рассчитываются с помощью какого-то трудоемкого алгоритма).
Я...
2707 просмотров
schedule
23.09.2022
Celery Period_task выполняется несколько раз параллельно
У меня есть очень простой периодический код, использующий потоки Celery; он просто печатает «Pre» и «Post» и спит между ними. Он адаптирован из этого вопроса StackOverflow и этот связанный веб-сайт
from celery.task import task
from...
2913 просмотров
schedule
21.02.2023
Celery - планировать периодические задачи, запускающиеся в определенное время
Каков наилучший способ запланировать периодическую задачу, начиная с определенной даты и времени?
(Я не использую cron для этого, учитывая, что мне нужно запланировать около сотни удаленных rsync, где я вычисляю удаленное и локальное смещение, и...
7686 просмотров
schedule
21.11.2022
Celery создает несколько экземпляров Task
Я создаю задачу (путем создания подкласса celery.task.Task), которая создает соединение с потоковым API Twitter. Для вызовов Twitter API я использую tweepy. Как я прочитал из документации celery, «задача не создается для каждого запроса, а...
1744 просмотров
schedule
10.02.2023
Как равномерно распределить задачи между узлами с помощью Celery?
Я использую Celery с Django для управления очередью задач и использую один (или несколько) небольших (одноядерных) экземпляров EC2 для обработки задачи.
У меня есть некоторые соображения.
Моя задача съедает 100% ЦП на одном ядре. - использует...
1176 просмотров
schedule
30.04.2023
Ведение журнала Django ломает демон celery
Я использую django 1.3 с django-celery 2.4.2 на производстве.
Поскольку я активировал ведение журнала django в файле django settings.py, демон celery (celeryd) больше не будет работать. Удаление функции ведения журнала устраняет проблему.
Мой...
544 просмотров
schedule
29.08.2023
методы объекта сельдерея python
Я пытаюсь получить оболочку задач сельдерея вокруг метода объекта python. Нравится:
class A:
@task
def test_task(self,args):
print "BLah..test"
def main():
a= A()
args = {}
a.test_task(args)
Теперь это...
2050 просмотров
schedule
02.09.2023
Зачем использовать Celery вместо RabbitMQ?
Насколько я понимаю, Celery - это распределенная очередь задач, что означает, что единственное, что он должен делать, - это отправлять задачи / задания на другие серверы и возвращать результат. RabbitMQ - это очередь сообщений и не более того....
28180 просмотров
schedule
19.01.2023
Работа с celerybeat как с единственной точкой отказа
Я ищу рекомендуемое решение для обхода celerybeat как единой точки отказа для развертывания celery/rabbitmq. Я не нашел ничего, что имело смысл до сих пор, поиск в Интернете.
В моем случае планировщик раз в день запускает серию заданий, которые...
1168 просмотров
schedule
29.09.2022
максимальное (ограниченное) значение для CELERYD_TASK_TIME_LIMIT?
мы делаем сумасшедшие забавные вещи с django-celery. Несколько наших задач требуют времени, и мы хотели бы позволить им делать свое дело. Я попытался установить для CELERYD_TASK_TIME_LIMIT большое значение, например 86400 (24 часа), но мои задачи...
1913 просмотров
schedule
24.08.2022
Как убедиться, что задача Celery предотвращает перекрытие выполнения задач Celery
Как запретить Celery выполнять периодическую задачу до того, как завершится предыдущее выполнение?
У меня есть кластер серверов, связанных с общим сервером базы данных, выполняющих задачи Celery, и я обнаружил, что каждый сервер может иногда...
2603 просмотров
schedule
29.01.2024
