我有几个工人,听不同的路线。我在应用程序中导入它们时使用:
from SlackStore import registra, cuantos
from cuentacomandos import cuenta
这样定义应用程序,然后声明路由
app = Celery('client', broker='amqp://')
app.conf.task_routes = { "SlackStore.*" : { 'queue': 'rutauno' },
"cuentacomandos.*" : { 'queue': 'ruta33' }
}
这些对象被称为regista。拖延等等。包含的任务的名称
celery inspect registered -A SlackStore
在应用程序日志中如上图所示。我错过了什么?