Celery AsyncResult获取主机名

Question

我有一个芹菜设置,使用两个不同的服务器来处理任务.我正在试图找出匹配任务完成的服务器的最佳方法.我查看了文档,但没有看到任何关于从AsyncResult检索主机名的信息.

关于此事的任何意见表示赞赏.我想要尝试的另一个选择是简单地将主机名放在每个芹菜配置中,虽然这种方法不是很理想,因为它还有一件事需要记住.

Answer 1

可能的解决方法是返回具有任务返回值的主机名

from celery import current_task

@celery.task
def hello(x, y):
  return dict(hostname=current_task.request.hostname, result='hello')