标题:Celery中的自动任务路由存在问题

2024-10-02 14:16:00 发布

您现在位置:Python中文网/ 问答频道 /正文

我有几个工人,听不同的路线。我在应用程序中导入它们时使用:

from SlackStore import registra, cuantos
from cuentacomandos import cuenta

这样定义应用程序,然后声明路由

app = Celery('client', broker='amqp://')

app.conf.task_routes = {  "SlackStore.*" : { 'queue': 'rutauno' },
                          "cuentacomandos.*" : { 'queue': 'ruta33' }
}

用register.delay等调用对象。应用程序日志中带有celery inspect registered -A SlackStore的任务的名称如上所示。我错过了什么


Tags: fromimportapp应用程序声明路由定义queue

热门问题