1

我正在使用Supervisor 的事件框架来订阅由 Supervisor 管理的进程的事件。

我的事件监听器，processlistener.py看起来像这样：

import sys

from supervisor.childutils import listener

def write_stdout(s):
    sys.stdout.write(s)
    sys.stdout.flush()


def write_stderr(s):
    sys.stderr.write(s)
    sys.stderr.flush()


def main():
    while True:
        headers, body = listener.wait(sys.stdin, sys.stdout)
        body = dict([pair.split(":") for pair in body.split(" ")])

        write_stderr("Headers: %r\n" % repr(headers))
        write_stderr("Body: %r\n" % repr(body))

        if headers["eventname"] == "PROCESS_STATE_RUNNING":
            write_stderr("Process state running...\n")


if __name__ == '__main__':
    main()

在我的supervisord.conf，我有：

[program:theprogramname]
command=/bin/cat              ; the program (relative uses PATH, can take args)
process_name=%(program_name)s_%(process_num)s ; process_name expr (default %(program_name)s)
numprocs=1                    ; number of processes copies to start (def 1)

[eventlistener:theeventlistenername]
command=python processlistener.py    ; the program (relative uses PATH, can take args)
process_name=%(program_name)s_%(process_num)s       ; process_name expr (default %(program_name)s)
numprocs=1                           ; number of processes copies to start (def 1)
events=PROCESS_STATE_RUNNING         ; event notif. types to subscribe to (req'd)

使用此配置，我希望只要由 Supervisor 管理的进程进入RUNNING状态，我的事件侦听器就会收到通知。然而，这种情况并非如此。theprogramname当我用信号杀死时SIGINT，主管重新启动了该过程，但我的侦听器没有收到此通知。

为了实现我想要的，我是否缺少额外的配置？

4

1 回答 1

3

这是因为您的侦听器需要在标准输出上将“RESULT 2\nOK”响应发送回 supervisord。

如果 supervisord 没有看到这个响应，它认为你的监听器还没有准备好，不会再发送任何事件。

尝试在你的 while 循环中添加这个：

listener.ok(sys.stdout)

这告诉侦听器发送“OK”响应。

以下是该ok方法的来源supervisor.childutils.listener： https ://github.com/Supervisor/supervisor/blob/3.0/supervisor/childutils.py#L61

于 2013-09-23T21:25:05.347 回答