python - 检查我所有的 worker 是否在线 celery

Question

我有两个 worker 在跑:

1. celery -A project worker -Q OneAtTimeQueue -c1 -l Info

2. celery -A project worker -B -l info

第一个是让任务一次执行一个。这就是为什么它有一个并发。

第二个用于其他任务，不需要一次完成，它是周期性任务的节拍。

当我使用:

celery -A project status

它只显示:

celery@project: OK

1 node online.

如何查看两个worker是否在线？

Answer 1

首先，要在不使用 -n 指定名称的情况下启动工作节点，您很可能会收到这样的 DuplicateNodenameWarning 警告:

/usr/local/lib/python3.4/site-packages/celery/app/control.py:36: DuplicateNodenameWarning: Received multiple replies from node name: celery@hostname.

其次，您可以使用 Celery 远程命令 Ping 检查所有在线工作人员(因为他们将以 pong 响应)，Ping 命令将广播 ping 到所有 Celery 工作节点并仅报告事件那些，I.E.

$ celery -A project inspect ping
celery@hostname: OK
        pong
celery@hostname: OK
        pong
/usr/local/lib/python3.4/site-packages/celery/app/control.py:36: DuplicateNodenameWarning: Received multiple replies from node name: celery@hostname.
Please make sure you give each node a unique nodename using the `-n` option.
  pluralize(len(dupes), 'name'), ', '.join(sorted(dupes)),