代码之家  ›  专栏  ›  技术社区  ›  jjmerelo

芹菜中的自动任务路由无法正常工作

  •  0
  • jjmerelo  · 技术社区  · 6 年前

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

    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 在应用程序日志中如上图所示。我错过了什么?

    0 回复  |  直到 6 年前