Вопросы по теме 'django-celery'
celerybeat автоматически отключает периодическую задачу
Я хочу создать периодическую задачу для сельдерея, используя интерфейс администратора django-celery . У меня настроена задача, которая отлично работает при вызове вручную или по сценарию. Он просто не работает через celerybeat . Согласно журналам...
4083 просмотров
schedule
10.06.2023
Celery: ограничения параллелизма для каждой задачи (количество рабочих на задачу)?
Можно ли установить параллелизм (количество одновременных рабочих процессов) на уровне каждой задачи в Celery ? Я ищу что-то более тонкое, чем CELERYD_CONCURRENCY (что устанавливает параллелизм для всего демона).
Сценарий использования: у меня...
11112 просмотров
schedule
10.09.2022
Как я могу запланировать задачу с Celery, которая выполняется в определенный день месяца?
Я пытаюсь использовать этот решение , но безуспешно. Как я могу указать день месяца, в который задача должна быть выполнена? Мое решение было
class DayOfMonth(schedule):
def __init__(self, day=1):
self.day = day
def...
650 просмотров
schedule
26.04.2023
Celerybeat — периодические задачи с Django
Я не уверен, как вещи сочетаются друг с другом..
У меня есть приложение с активными кампаниями, которое объявляет победителей и т. д., а также отправляет напоминания о кампаниях. Кампания создана с помощью django, и в модели кампании у меня есть...
595 просмотров
schedule
16.05.2024
Django и Celery: список задач администратора не отображает значения
Моя проблема должна быть довольно простой и скорее представляет интерес, чем то, что нужно отчаянно решать. Google не смог дать мне ответ, который я искал, поэтому я надеюсь, что ваш опыт поможет мне. Я использую:
Django 1.4
Celery 2.5.5
Redis...
2049 просмотров
schedule
01.11.2022
Неправильная конфигурация или ошибка часового пояса Django Celery
Я обновил свой проект Django (с celery==2.5.5 и django-celery==2.5.5 ) до celery==3.0.7 и django-celery==3.0.6 . А потом произошли странные вещи.
Первое, что я заметил, это то, что каждая дата/время в интерфейсе администратора Django Celery...
4166 просмотров
schedule
04.11.2023
Очистка задачи сельдерея с помощью бэкэнда БД
Я пытаюсь понять, как и когда задачи очищаются в сельдерее. Глядя на документацию задачи , я вижу, что :
Старые результаты будут очищены автоматически на основе параметра CELERY_TASK_RESULT_EXPIRES. По умолчанию срок действия истекает через...
10931 просмотров
schedule
01.12.2023
Путаница Джанго и Сельдерея
Прочитав много сообщений в блогах, я решил переключиться с crontab на Celery для своего среднего проекта Django. У меня есть несколько вещей, которые я не понял:
1- Я планирую запустить экземпляр micro EC2, который будет посвящен RabbitMQ, будет...
271 просмотров
schedule
29.11.2022
Задача Celery с несколькими декораторами без автоматической регистрации имени задачи
У меня есть задача, которая выглядит так
from mybasetask_module import MyBaseTask
@task(base=MyBaseTask)
@my_custom_decorator
def my_task(*args, **kwargs):
pass
и моя базовая задача выглядит так
from celery import task, Task
class...
2505 просмотров
schedule
28.05.2023
подкласс сельдерея Задача
Я пишу много задач, которые очень похожи, и хочу знать, как лучше создать подкласс Task , чтобы уменьшить шаблон. Поскольку задача запускается только один раз, вы не можете помещать вещи в __init__ , как показано ниже, но это должно...
8341 просмотров
schedule
08.10.2022
celery — объединение групп и подзадач. -› внеочередное исполнение
Когда у меня есть что-то вроде следующего
group1 = group(task1.si(), task1.si(), task1.si())
group2 = group(task2.si(), task2.si(), task2.si())
workflow = chain(group1, group2, task3.si())
Интуитивная интерпретация состоит в том, что задача...
16805 просмотров
schedule
21.04.2024
Задача Django celery: недавно созданная модель DoesNotExist
Почему экземпляр модели, который я создал, при запросе из задачи сельдерея, запущенной сразу после этого, не найден? Например:
# app.views
model = Model.objects.create() # I create my lovely model in a view
from app.tasks import ModelTask #...
2495 просмотров
schedule
10.08.2022
Остановка Supervisor не останавливает работников Celery
Как обеспечить остановку подпроцессов при остановке Supervisord?
Я использую Supervisord для запуска двух работников Celery. Команда для каждого работника:
command=/usr/local/myapp/src/manage.py celery worker --concurrency=1 --loglevel=INFO...
10648 просмотров
schedule
25.08.2022
Celery @task не работает с методами экземпляра
У меня есть класс с методами, украшенными сельдереем @task следующим образом:
class Port(object):
"""docstring for Port"""
def __init__(self,):
print 'Class has been initialized ...'...
4451 просмотров
schedule
28.10.2022
Сельдерей, создайте подзадачу внутри задачи: получена незарегистрированная задача типа
Используя django-celery, я пытаюсь создать некоторые подзадачи из основной задачи, но получаю эту ошибку: получена незарегистрированная задача типа «smallTask».
Любая идея, что не так, пожалуйста? И если это правильный способ создавать подзадачи...
391 просмотров
schedule
26.05.2023
Celeryd - отправить электронное письмо при ошибке на уровне журнала и выше
Мы настроили django на отправку нам электронных писем при любой ошибке или выше, которая срабатывает. Это делается с помощью стандартной конфигурации LOGGING в Django. Я хочу такого же поведения в сельдерее. У меня работает отправка электронных...
1627 просмотров
schedule
24.10.2022
Декоратор после декоратора @task в celery
Я пытаюсь применить декоратор после декоратора celery @task, что-то вроде.
@send_email
@task
def any_function():
print "inside the function"
Я могу заставить его работать так, как это рекомендуется в документации, т. е. поместить...
8696 просмотров
schedule
01.11.2023
Как отключить задачи сельдерея при тестировании на django
Я пытаюсь протестировать некоторые функции, которые включают вызов задач сельдерея. задачи включают вызов сторонних веб-сайтов, и мне нужно избегать этого во время тестов.
Любая идея, как отключить все задачи сельдерея во время тестов?
1480 просмотров
schedule
10.03.2023
Высокая доступность Redis
У меня есть проект django, который в настоящее время использует кеш Redis как в качестве моего брокера сельдерея, так и в качестве моего обычного кеша. Мне нравится эта установка, потому что она решает 2 мои потребности с помощью 1 технологии....
885 просмотров
schedule
31.07.2022
Django select_for_update в задаче сельдерея и состоянии гонки и уникален вместе
В приложении есть соответствующие модели: Company, Node и Log.
class VCompany(models.Model):
company_name = models.CharField(max_length=50, ...)
class VNode(models.Model):
company = models.ForeignKey(VCompany, ...)...
1135 просмотров
schedule
08.10.2023
