2

我有一个任务列表，其中包含在不同工作节点上使用 celery 执行程序运行的任务列表。但是，我想在主节点上运行其中一项任务。那可能吗？

4

1 回答 1

1

对的，这是可能的。您可以设置特定任务来监听Celery 中的特定队列。气流文档很好地涵盖了它，但它的要点是：

  1. 将表示您要在特定节点上运行的任务的运算符上的队列属性设置为与中的值不同的celery -> default_queue值airflow.cfg

  2. 通过指定它需要侦听的队列，在您的主节点上运行工作进程airflow worker -q queue_name。如果您希望您的工作人员监听多个队列，您可以使用逗号分隔列表airflow worker -q default_queue,queue_name

于 2017-07-25T08:36:53.147 回答