我有几个工人,听不同的路线。我在应用程序中导入它们时使用:
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
的任务的名称如上所示。我错过了什么
目前没有回答
相关问题 更多 >
编程相关推荐