Вот уже около года это работает без проблем, но, похоже, внезапно перестал работать на прошлой неделе или в две, и я не уверен, где искать.
Чтобы запустить сельдерей, я просто запускаю эту команду:
PYTHONPATH=[path to project]:. celery -A update.tasks worker -Q update_local --concurrency 2 -E
Вкл. AWS У меня есть настройка SQS с именем update_local.
В файле конфигурации celery. У меня есть файл BROKER_URL = sqs://[AWS:KEYS]@ для учетной записи, которая имеет update_local очередь SQS.
Когда я запускаю ее сейчас, я получаю:
[2020-03-10 22:26:23,789: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 2.00 seconds...
Снова и снова.
Мне удалось заставить его работать без ошибок, но я должен указать файл конфигурации с флагом --config. Не уверен, почему он больше не находит файл сам по себе.