小编vpo*_*pol的帖子

在引导步骤添加芹菜队列

我想做两件事

  1. 我做了一个从远程加载配置的工人引导步骤。
  2. 我想从配置中获取一个参数并添加一个队列,并将其设置为消费者队列名称。

app.steps['worker'].add(LoadConfig)

完美无缺

但我无法进行 SetQueue 启动步骤

只是我的 SetQueue 现在看起来像:

class SetQueue(bootsteps.StartStopStep):

    requires = (Consumer, )

    def start(self, parent, **kwargs):

        parent.add_task_queue('q_name', exchange='q_name', routing_key='q_name')

app.steps['consumer'].add(SetQueue)
Run Code Online (Sandbox Code Playgroud)

它不起作用。

我认为我的问题是我不明白 - 在什么时候(requires=(???, )) 可以添加队列。

python celery

1
推荐指数
1
解决办法
1159
查看次数

标签 统计

celery ×1

python ×1