После нескольких разочаровывающих дней мне нужно посмотреть на отладку рабочего процесса сельдерея в VSCode. Это соответствует предложенному процессу в документах Celery для создания обработчика сообщений, а не публикации/подписки из того же приложения.
Файл celery.py:
from __future__ import absolute_import, unicode_literals
import os
import json
from celery import Celery, bootsteps
from kombu import Consumer, Exchange, Queue
dataFeedQueue = Queue('statistical_forecasting', Exchange('forecasting_event_bus', 'direct', durable=False), 'DataFeedUpdatedIntegrationEvent')
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings.local')
app = Celery('statistical_forecasting')
app.config_from_object('django.conf:settings', namespace='CELERY')
# Not required yet as handler is within this file
#app.autodiscover_tasks()
class DataFeedUpdatedHandler(bootsteps.ConsumerStep):
def get_consumers(self, channel):
return [Consumer(channel, queues=[dataFeedQueue], callbacks=[self.handle_message], accept=['json'])]
def handle_message(self, body, message):
event = json.loads(body)
# removed for brevity, but at present echo's message content with print
message.ack()
app.steps['consumer'].add(DataFeedUpdatedHandler)
Моя сокращенная структура проекта:
workspace -
vscode -
- launch.json
config -
__init__.py
settings -
local.py
venv -
celery.exe
statistical_forecasting -
__init__.py
celery.py
farms -
__init__.py
handlers.py # ultimately handler code should live here...
С терминала с venv enable я запускаю celery -A statistical_forecasting worker -l info, который, похоже, успешно настраивает и запускает базовый обработчик сообщений.
До сих пор я пробовал с VSCode настроить следующую конфигурацию в launch.json
{
"version": "0.2.0",
"configurations": [
{
"name": "Python: Celery",
"type": "python",
"request": "launch",
"module": "celery",
"console": "integratedTerminal",
//"program": "${workspaceFolder}\\env\\Scripts\\celery.exe",
"args": [
"worker",
"-A statistical_forecasting",
"-l info",
]
},
]
}
К сожалению, это просто приводит к следующему сообщению:
Error:
Unable to load celery application.
The module statistical_forecasting was not found.
Логически я могу предположить, что отладка должна выполняться celery из каталога рабочей области и что он должен видеть каталог statistical_forecasting с техническим __init__.py, что делает его модулем?
Я пробовал другие различные идеи, такие как форсирование виртуальной среды program в lauch.json и т. д., но все они возвращались с одним и тем же основным сообщением об ошибке.
'init.py' в статистическом_прогнозировании содержит стандартную настройку Django, и я не уверен, что она требуется, поскольку задача celery выполняется вне Django, и я не собираюсь публиковать/получать из Django заявление.
