主管活動：如何監聽所有或指定進程的PROCESS_STATE_STOPPED事件

Question

我試圖使用supervisord事件來監聽Supervisor管理的進程中的PROCESS_STATE_STOPPED事件。

我的事件監聽器（listener.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)) 
     listener.ok(sys.stdout) 

     if headers["eventname"] == "PROCESS_STATE_STOPPED": 
      write_stderr("Process state stopped...\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_name expr (default %(program_name)s) 
numprocs=1     ; number of processes copies to start (def 1) 
... 
[eventlistener:theeventlistenername] 
command=python /home/mickm/listener.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     ; event notif. types to subscribe to (req'd) 
autorestart=true 
redirect_stderr=true 

我已經研究了這個區域&其他StackOverflow的問題我試圖實施公認的解決方案：

• How to subscribe to PROCESS_STATE_RUNNING events for all processes
• Supervisor event subscription is hanging on READY state

然而，當我運行listener.py，輸出READY到SDOUT &去沒有進一步。我試過停止/啓動&重新啓動監督進程，但我的腳本確實收拾任何東西。

爲了測試這一點，我：

1. 運行在終端我的事件偵聽器的腳本;
2. 在終端B.在/bin/cat過程進行kill -9 <pid>

我的上司日誌如下：

2017-01-13 14:56:36,168 INFO success: theeventlistenername_0 entered RUNNING state, process has stayed up for > than 1 seconds (startsecs) 
2017-01-13 14:56:36,168 INFO success: theprogramname entered RUNNING state, process has stayed up for > than 1 seconds (startsecs) 
2017-01-13 14:57:29,457 INFO exited: theprogramname (terminated by SIGKILL; not expected) 
2017-01-13 14:57:30,460 INFO spawned: 'theprogramname' with pid 25788 
2017-01-13 14:57:31,462 INFO success: theprogramname entered RUNNING state, process has stayed up for > than 1 seconds (startsecs) 

雖然主管日誌知道我的進程已被終止：

i）listener.py沒有檢測到任何東西，它保持'READY'提示。

ii）監督員重新啓動以處理（如預期的）。

我想知道爲什麼聽衆沒有收到配置文件中定義的程序的PROCESS_STATE_STOPPED事件（按照Supervisor事件docs）。另外 - 這是否可以普遍適用於所有主管管理的流程。

謝謝。

Answer 1

配置可變redirect_stderr的：

http://supervisord.org/configuration.html

不要設置了redirect_stderr =真在[事件偵聽：X]部分。 事件監聽器使用stdout和stdin與supervisord進行通信。 如果stderr被重定向，stderr的輸出將會干擾事件監聽器協議。

這是我的工作腳本了：

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_STOPPING": 
      write_stderr("Process state stopping...\n") 

     # acknowledge the event 
     write_stdout("RESULT 2\nOK") 

但我相信你無法測試它只是運行你的腳本。你supervisorctl .conf文件具有類似事件其犯規一些特殊的ENV變量如果你想測試它，然後添加一些記錄到您的收聽，當你手動運行腳本

出現：

[eventlistener:theeventlistenername] 
command=python /home/mickm/listener.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   ; event notif. types to subscribe to (req'd) 
autorestart=true 
stderr_logfile=errorlogfile 
stdout_logfile=applogfile 

你也可以調試標頭變量，您可以檢查您收到的數據。

通過啓用日誌記錄，你可以用尾-f在stderr_logfile日誌文件error.log.path測試。

Headers: "{'ver': '3.0', 'poolserial': '4', 'len': '71', 'server': 'supervisor', 'eventname': 'PROCESS_STATE_RUNNING', 'serial': '4', 'pool': 'mylistener'}" 
Body: "{'from_state': 'STARTING', 'processname': 'someprocess', 'pid': '345', 'groupname': 'someprocess'}" 
Process state running... 

而當我kil -9過程上述輸出出現在日誌中。

另外，stdout_logfile將記錄這樣的信息：

RESULT 2 
OKREADY 
RESULT 2 
OKREADY 
RESULT 2 
OKREADY 
RESULT 2 
OKREADY 
RESULT 2 
OKREADY