无法从 python shell 运行 celery 任务

问题描述

我正在尝试使用本地机器内的 python shell 中的 .delay() 异步运行 celery 任务，celery 使用 rabbitmq 作为代理，并且 celery 和 rabbitmq 服务器都在 2 个不同的 docker 容器中运行。这里的问题是芹菜工人没有连接到rabbitmq 服务器

这是我在这里使用的配置

# celery config
    CELERY_ALWAYS_EAGER = False
    #Default config
    CELERY_broKER = "amqp://rabbitmq:5672"

    #default config
    CELERY_RESULT_BACKEND = "redis://redis:6379/15"

docker 容器端口映射到主机的各个端口。

解决方法

我认为您的后端配置也应该是 Rabbitmq。请尝试将以下代码合并为后端。希望能有所帮助！ CELERY_RESULT_BACKEND = ='rpc://'