Пытаюсь разобраться с Celery + RabbitMQ. RebbitMQ запущен локально, celery

Question

Пытаюсь разобраться с Celery + RabbitMQ. RebbitMQ запущен локально, celery

запущен внутри виртуального окружения запустил командой celery -A tasks worker --loglevel=INFO из окна консоли PyCharm
Задача, которая должна выполняться (tasks.py вязата из доки)
from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

@app.task
def add(x, y):
return x + y

Запуск происходит так (взято из доки):
from tasks import add
add.delay(4, 4)
В логах celery видно, что принята задача, но далее ничего не происходит.

...
[2023-08-17 15:59:59,211: INFO/SpawnPoolWorker-4] child process 13984 calling self.run()
[2023-08-17 15:59:59,222: INFO/SpawnPoolWorker-6] child process 13516 calling self.run()
[2023-08-17 15:59:59,341: INFO/MainProcess] mingle: all alone
[2023-08-17 15:59:59,371: INFO/MainProcess] celery@DESKTOP-85D1D38 ready.
[2023-08-17 15:59:59,371: INFO/MainProcess] Task tasks.add[52facbae-7f89-4378-8fbf-1cdc621b36f0] received

Что я делаю не так?

#backend #programming #python #russian

0

17.08.2023

1 ответов

26 просмотров

Leonid · Accepted Answer

Leonid

Кодишь на питоне (не бейте за шутку пж)

0

17.08.2023

170 похожих чатов

Пытаюсь разобраться с Celery + RabbitMQ. RebbitMQ запущен локально, celery

1 ответов

Похожие вопросы