Celery - это среда распределенной очереди задач для Python, используемая для асинхронного и параллельного выполнения.
Я новичок в брокерах сообщений, таких как RabbitMQ, которые мы можем использовать для создания задач / очередей сообщений для системы планирования, такой как Celery . Теперь вот вопрос: Я могу создать таблицу в PostgreSQL, к которой можно добавлять новые задачи и использовать такую...
Как я могу удалить все отложенные задачи, не зная task_idдля каждой
Как я могу получить список задач в очереди, которые еще предстоит
В документации Celery упоминается тестирование Celery в Django, но не объясняется, как протестировать задачу Celery, если вы не используете Django. Как ты делаешь
Закрыто . Этот вопрос должен быть более конкретным . В настоящее время он не принимает ответы. Хотите улучшить этот вопрос? Обновите вопрос, чтобы он фокусировался только на одной проблеме, отредактировав этот пост . Закрыт 3 года назад . Уточните этот вопрос В настоящее время я работаю над...
Я пытаюсь запустить пример из документации Celery. Я бегу: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." % (configname, )))...
Я читал документ и искал, но, похоже, не нашел прямого ответа: Можете ли вы отменить уже выполняющуюся задачу? (так как задача запущена, занимает некоторое время, и ее нужно отменить на полпути) Я нашел это из документа в FAQ по сельдерею >>> result = add.apply_async(args=[2, 2],...
Как проверить, выполняется ли задача в сельдерее (в частности, я использую celery-django)? Я прочитал документацию и погуглил, но не вижу вызова вроде: my_example_task.state() == RUNNING Мой вариант использования заключается в том, что у меня есть внешняя (java) служба для перекодирования. Когда я...
Мне трудно понять назначение «распределенных очередей задач». Например, библиотека сельдерея python . Я знаю, что в сельдерее, фреймворке Python, вы можете установить временные окна для выполнения функций. Однако это также можно легко сделать в Linux crontab, направленном на скрипт python....
Я пытаюсь придумать методологию тестирования для нашего проекта django-celery . Я прочитал примечания в документации , но это не дало мне хорошего представления о том, что на самом деле делать. Я не беспокоюсь о тестировании задач в реальных демонах, а только о функциональности моего кода. В...
У меня есть задача Celery с интенсивным использованием ЦП. Я хотел бы использовать всю вычислительную мощность (ядра) во множестве экземпляров EC2, чтобы выполнить эту работу быстрее ( я думаю, параллельная распределенная задача сельдерея с многопроцессорностью ) . Я пытаюсь лучше понять термины,...
Я только что узнал о параметре конфигурации CELERYD_PREFETCH_MULTIPLIER( документы ). По умолчанию - 4, но (я считаю) я хочу, чтобы предварительная выборка была отключена или как можно меньше. Сейчас я установил его на 1, что достаточно близко к тому, что я ищу, но есть еще кое-что, чего я не...
Предположим, у меня есть модель Event. Я хочу отправить уведомление (электронная почта, push, что угодно) всем приглашенным пользователям после того, как событие прошло. Что-то вроде: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited =...