确定芹菜任务来自哪个队列

Question

假设我在一个芹菜任务中。有没有办法确定任务的来源。假设机器正在监听队列a、队列B、队列C，当任务进入时，有办法确定它是否来自队列B吗？或者，有没有一种方法可以检查机器在任务内部监听哪些队列？

@task
def myfunc():
# which queue did this current task originate from? Or what queue(s) is this machine connected to?

Answer 1

以下内容应该有效：

@app.task(name="myapp.myfunc", bind=True)
def myfunc():
# which queue did this current task originate from? Or what queue(s) is this machine connected to?
task_queue = self.request.delivery_info['routing_key']

其中"；应用程序"；是芹菜的一个实例。