celerybeat shutdown - initscript 命令？

Question

我正在尝试设置rabbitmq/celery/django-celery/django，以便它是“防重启”的，即它会自行恢复。一切似乎都工作正常，除了这个：

当我重新启动时，所有服务都启动，但似乎 celeryd 在rabbitmq之前启动，并且celerybeat随后终止，因为它无法连接（？）：

[2011-06-14 00:48:35,128: WARNING/MainProcess] celery@inquire has started.
[2011-06-14 00:48:35,130: INFO/Beat] child process calling self.run()
[2011-06-14 00:48:35,131: INFO/Beat] Celerybeat: Starting...
[2011-06-14 00:48:35,134: ERROR/MainProcess] Consumer: Connection Error: [Errno 111] Connection refused. Trying again in 2 seconds...
[2011-06-14 00:48:35,688: INFO/Beat] process shutting down
[2011-06-14 00:48:35,689: WARNING/Beat] Process Beat:
[2011-06-14 00:48:35,689: WARNING/Beat] Traceback (most recent call last):
...
[2011-06-14 00:48:35,756: WARNING/Beat] File "/home/inquire/inquire.env/lib/python2.6/site-packages/amqplib/client_0_8/transport.py", line 220, in create_transport
[2011-06-14 00:48:35,760: WARNING/Beat] return TCPTransport(host, connect_timeout)
[2011-06-14 00:48:35,761: WARNING/Beat] File "/home/inquire/inquire.env/lib/python2.6/site-packages/amqplib/client_0_8/transport.py", line 58, in __init__
[2011-06-14 00:48:35,761: WARNING/Beat] self.sock.connect((host, port))
[2011-06-14 00:48:35,761: WARNING/Beat] File "<string>", line 1, in connect
[2011-06-14 00:48:35,761: WARNING/Beat] error: [Errno 111] Connection refused
[2011-06-14 00:48:35,761: INFO/Beat] process exiting with exitcode 1
[2011-06-14 00:48:37,137: ERROR/MainProcess] Consumer: Connection Error: [Errno 111] Connection refused. Trying again in 4 seconds...

在Ubuntu上，我安装了rabbitmq-server apt、django-celery 和 pip 到我的 virtualenv 中，然后我符号链接了从 https://github.com/ask/celery/tree/master/contrib /etc/init.d 中的 /debian/init.d ，在 /etc/default/celeryd 中将其配置为使用我的 virtualenv 中的 django celeryd，并通过（也许“默认值”是问题？）

update-rc.d celeryd defaults

我没有使用单独的初始化脚本运行 celeryd 和 celerybeat，而是将 celeryd 配置为包含 Beat（也许这就是问题所在？）：

CELERYD_OPTS="-v 2 -B -s celery -E"

有任何指示如何解决此问题吗？

如果我

sudo /etc/init.d/celeryd restart

没有抱怨：

[2011-06-14 00:54:29,157: WARNING/MainProcess] celery@inquire has started.
[2011-06-14 00:54:29,161: INFO/Beat] child process calling self.run()
[2011-06-14 00:54:29,162: INFO/Beat] Celerybeat: Starting...

但我需要消除任何手动步骤的需要。

Answer 1

celerybeat 对代理服务的依赖确实是问题所在。
安装 initscript

update-rc.d celeryd defaults

celerybeat 的依赖关系必须通过在rabbitmq-server 之后显式启动（并在之前杀死它）来解决，而不是使用rabbitmq-server 脚本作为启动和终止的序列号20

update-rc.d celeryd defaults 21 19

：我实际上已经选择单独的 celerybeat 服务而不是 -B 调用，并且只对那个脚本（即有问题的脚本）执行了 21 19 。

Answer 2

我认为问题不在于 celery 本身，而是在于您的脚本中，可能当 celeryd 启动时，代理尚未侦听。
我使用的命令几乎与您相同，没有任何问题，使用 -B 选项启动 celeryd 脚本没有错误。
我认为在您的重新启动脚本中，您必须等待rabbitmq完全重新启动才能启动celeryd，也许也需要进行连接测试。