Я использую Celery + Kombu с Amazon SQL. Цель состоит в том, чтобы иметь возможность удалить задачу, уже запланированную на определенную дату и время. я пробовал from celery.task.control import revoke revoke(task_id) но это ничего не...

Я пытаюсь настроить кластер RabbitMQ высокой доступности с зеркальными очередями. На самом деле, я это настроил, и это была легкая часть. Теперь наступает та часть, где моим производителям и потребителям нужен доступ к кластеру или, в частности, к...

Я запускаю онлайн-игру с Django 1.6 и Celery 3.1.11. Комбу 3.0.15. Недавно у меня были проблемы с Celery и DST, поэтому я решил запустить весь сайт в UTC и избавить себя от беспокойства о часовых поясах. Соответствующие части моего settings.py:...

Я новичок в celery, пытаюсь отправить электронную почту, но не могу получить почту. settings.py import djcelery djcelery.setup_loader() BROKER_URL = 'django://' INSTALLED_APPS = ( 'grappelli', 'django.contrib.admin', 'django.contrib.auth',...

Попробуйте заставить его работать: Django 1.6.11 + Celery 3.1.19 + Kombu 3.0.33 в Ubuntu 14.04, используя учебник http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html , поэтому я полностью повторил структуру проекта отсюда :...

Я использую Django + Celery + Kombu + rabbitmq: моя задача успешно выполнена на сервере (Ubuntu 14.04) [2016-01-21 02:29:05,027: INFO/MainProcess] Task vk_wall.tasks.get_wallposts_by_owner_id[cbdfbdf7-1f01-4cf1-bd5a-77fae7a07003] succeeded in...

Я использую: celery==3.1.12 kombu==3.0.19 amqp==1.4.5 Рабочий сельдерея был запущен: celery worker --without-gossip --without-heartbeat --without-mingle Сельдерей настройки: CELERY_ALWAYS_EAGER = False...

У меня есть два сервера, назовем их A и B. B запускает RabbitMQ, а A подключается к RabbitMQ через Kombu. Если я перезапущу RabbitMQ на B, соединение kombu разорвется, и сообщения больше не будут доставляться. Затем мне нужно сбросить процесс на A,...

У меня есть 3 узла RabbitMQ в кластере в режиме HA. Каждый узел находится в отдельном контейнере Docker. Я использую Celery версии 4 и комбу версии 4. Я использовал эту команду для установки политики HA: rabbitmqctl set_policy ha-all ""...

Я получаю ERROR EncodeError(TypeError('6JQAKHNMG9 is not JSON serializable',),) после обновления. Успешно установлен: amqp-2.1.4 бильярд-3.5.0.2 сельдерей-4.0.2 комбу-4.0.2 pytz-2017.2 (Изначально требуется для установки Flower...

У меня проблемы с публикацией сообщений с помощью kombu 4.1. Мой вариант использования заключается в том, что у меня есть сервер, который собирает сообщения из очереди rabbitmq (очередь 1), выполняет некоторую задачу обработки, а затем повторно...

В настоящее время я пишу чат-мессенджер, используя GRPC/RabbitMQ для групповых чатов. У меня есть API в Django/DRF, который обрабатывает журналы аутентификации/сообщений/текстовые и электронные оповещения и т. д. Для этого я хотел бы создать...

Я пытаюсь создать несколько фоновых celery beat процессов, используя docker-compose , но они больше не работают. Моя конфигурация: docker-compose-dev.yml worker-periodic: image: dev3_web restart: always volumes: -...

Когда я пытаюсь отправить свою задачу брокеру (RabbitMQ), она зависает. # python shell promise = foo.s(first_arg="2").apply_async() # blocking indefinitely. I expected a promise object. Если я запускаю задачу синхронно, она работает...