Вопросы по теме 'celery-task'
Реализация Django Celery - OSError: [Errno 38] Функция не реализована
Я установил django-celery и попытался запустить рабочий сервер, но получил ошибку OSError о том, что функция не реализована. Я использую CentOS версии 5.4 (Final) на VPS:
. broker -> amqp://guest@localhost:5672/
. queues ->...
7259 просмотров
schedule
29.09.2022
Удаление всех незавершенных задач в celery / rabbitmq
Как я могу удалить все незавершенные задачи, не зная task_id для каждой задачи?
138004 просмотров
schedule
03.05.2022
Как сделать так, чтобы задача сельдерея не удалась из задачи?
При некоторых условиях я хочу, чтобы задача сельдерея не выполнялась из этой задачи. Я пробовал следующее:
from celery.task import task
from celery import states
@task()
def run_simulation():
if some_condition:...
18944 просмотров
schedule
14.04.2023
Незарегистрированная задача в Celery
tasks.py:
from celery import Celery
from django.http import HttpResponse
from anyjson import serialize
celery = Celery('tasks', broker='amqp://guest@localhost//')
#@celery.task
def add(request):
x = int(request.GET['x'])
y =...
390 просмотров
schedule
24.12.2022
Celery multi не работает должным образом
У меня есть структура папок моего проекта
api
-- __init__.py
--jobs/
-- __init__.py
-- celery.py
-- celeyconfig.py
-- tasks.py
--api_helpers/
--views/
tasks есть задача под названием...
2914 просмотров
schedule
15.04.2023
Как отключить задачи сельдерея при тестировании на django
Я пытаюсь протестировать некоторые функции, которые включают вызов задач сельдерея. задачи включают вызов сторонних веб-сайтов, и мне нужно избегать этого во время тестов.
Любая идея, как отключить все задачи сельдерея во время тестов?
1480 просмотров
schedule
10.03.2023
Как запустить сельдерей в качестве демона с помощью обычной команды celery
У меня есть приложение django, для которого я использую задачи сельдерея для выполнения некоторой обработки csv в фоновом режиме, поэтому я установил rabbitmq-server как sudo apt-get install rabbitmq-server , с помощью этой команды сервер rabbitmq...
1403 просмотров
schedule
09.09.2022
Выполнение скрипта Python в качестве задачи Celery
Я пытаюсь запустить скрипт Python как задачу сельдерея с Django. Проблема, с которой я сталкиваюсь, заключается в том, что задача считает ее завершенной, как только скрипт начинает работать. Первоначально я использовал subprocess.popen() в файле...
3473 просмотров
schedule
04.12.2022
Запуск методов на основе классов в качестве задач Celery
У меня проблемы с запуском задач при настройке в качестве методов класса. Я прочитал о celery.contrib.methods . из ответа здесь на SO , но я не могу применить его к моему делу.
celery_conf.celeryapp.py
from __future__ import...
916 просмотров
schedule
09.05.2023
Перекодировать видео с помощью сельдерея и ffmpeg в django
Я хотел бы перекодировать загруженные пользователем видео с помощью сельдерея. Я думаю, что сначала я должен загрузить видео и создать задачу сельдерея для перекодирования.
Может быть, что-то вроде этого в tasks.py:
subprocess.call('ffmpeg -i...
2057 просмотров
schedule
12.03.2023
Как сделать две задачи взаимоисключающими в Celery?
Есть ли способ запретить одновременное выполнение двух разных задач в Celery? Я думал об определении новой очереди с уровнем параллелизма = 1 и отправке этих задач в эту очередь, но не смог найти пример. Это возможно?
Спасибо!
433 просмотров
schedule
15.05.2024
Пул Celery + Gevent зависает после выполнения 1000+ задач
У нас есть 8 ядер, 16 ГБ памяти, сервер Linux с сельдереем, на нем запущена рабочая очередь сельдерея myQueue и работает с параллелизмом 1000 в пуле gevent.
После выполнения задач около 1 часа рабочий внезапно зависает, он не принимает новые...
2399 просмотров
schedule
03.07.2023
Загадочный несвязанный task_id возвращается для рабочего процесса сельдерея.
У меня есть довольно сложный рабочий процесс (который строится динамически), который выглядит примерно так:
workflow= chain(
signature('workflow.tasks.start_workflow', kwargs= {}),
chord(
[
signature('workflow.tasks.group_task',...
66 просмотров
schedule
29.07.2023
Разделите общую функцию полезности между задачами Celery
У меня есть куча задач в Celery, все они связаны с помощью canvas chain .
@shared_task(bind=True)
def my_task_A(self):
try:
logger.debug('running task A')
do something
except Exception:
run common cleanup function...
739 просмотров
schedule
29.07.2023
извлечение кеша Redis в сериализатор django rest framework
Я использую Redis для кеширования. Я пытаюсь получить данные кэша Redis из сериализатора.
мой код:
class CocView(APIView):
"""
Celery and Redis Usage
"""
def get(self,request):
data = cache.get('alldata')
print "In the Cache",data...
1637 просмотров
schedule
10.10.2022
Задачи, повторяющиеся в Celery
Через пару дней мой сельдерейный сервис будет бесконечно повторять задачу снова и снова. Это несколько сложно воспроизвести, но это происходит регулярно раз в неделю или чаще в зависимости от объема обрабатываемых задач.
Я буду признателен за...
2169 просмотров
schedule
07.04.2022
Django Celery: объект модели не существует в задаче сельдерея (ATOMIC_REQUESTS = False)
Я получаю ошибку MyModel matching query does not exist. при извлечении объекта, который я создаю перед входом в задачу сельдерея. Я вызываю задачу из своего APIView .
my_model_obj = MyModel(x=1, y=2)
my_model_obj.save()...
690 просмотров
schedule
05.10.2022
Состояние задачи запроса — Celery и Redis
Итак, у меня есть относительно простая проблема, и я думаю, что я ударяюсь ею о кирпичную стену. У меня есть фляжное приложение и веб-страница, которая позволяет вам запускать ряд скриптов на стороне сервера, используя сельдерей и Redis (брокер)....
2338 просмотров
schedule
09.07.2022
задача сельдерея не может импортировать ImportError модуля из проекта
Я хотел бы отметить, что следующая ошибка возникает только при запуске через celery worker. с помощью следующей команды в терминале:
celery -A MarketPlaceTasks worker --loglevel=info
Traceback (most recent call last):
File...
775 просмотров
schedule
10.05.2023
Производство демона Celery не может импортировать ошибку Celery
Я следую всем инструкциям документов Celery. Сначала я следую этой ссылке , чтобы создать производственный процесс, и вот мой код приложения.
1-test_celery/celery.py:-
from __future__ import absolute_import
import os
from celery import...
161 просмотров
schedule
22.08.2022
