supervisor_twiddler的使用

Supervisor可以很好的实现Python的进程管理，但是新增进程时需要配置文件，对于需要动态创建进程的场景不是很友好，supervisor_twiddler插件可以帮助实现上述功能。本文就supervisor_twiddler的使用做简单的demo，详细内容可以查阅https://github.com/mnaberez/supervisor_twiddler

1. 安装

pip install supervisor_twiddler

2. 准备待管理的进程

这里使用一个faskapi的demo做为稍后supervisor管理的进程

from fastapi import FastAPI

app = FastAPI()

@app.get("/")
async def hello():
  return "hello world, guoxingyu"

3. 修改supervisord.conf

supervisord.conf的改动有两个：第一是目前看supervisor_twiddler推荐给已有的组添加进程，所以需要在supervisord.conf中添加组名；第二是添加[rpcinterface:twiddler]，内容如下：

[group:test]

[rpcinterface:twiddler]
supervisor.rpcinterface_factory = supervisor_twiddler.rpcinterface:make_twiddler_rpcinterface

4. 通过supervisor_twiddler实现进程管理

from xmlrpc.client import ServerProxy

if __name__ == '__main__':
  # 通过user、passwd连接supervisor的RPC服务
  server = ServerProxy("http://user:123@localhost:9001/RPC2")

  # 打印目前的Group list
  print(server.twiddler.getGroupNames())

  # 动态新增process
  server.twiddler.addProgramToGroup('test', 'helloworld', \
    {'command': 'gunicorn fastapidemo:app -b 0.0.0.0:8088 -w 1 -k uvicorn.workers.UvicornWorker', 'autostart':'true', 'autorestart':'true'})
  
  # 停止process并删除
  server.supervisor.stopProcess("test:helloworld")
  server.twiddler.removeProcessFromGroup("test", "helloworld")

  # 查看process日志
  print(server.supervisor.tailProcessStderrLog("test:helloworld",0,512))

这里主要实现了动态新增进程，关闭进程，查看日志三个子功能。

其中addProgramToGroup的具体参数可以看Github原文，第一个是Group名、第二个是process名，第三个是dict，包括supervisor配置的一些参数。

效果：

1597413548058.jpg 1597413609608.jpg

不过supervisor_twiddler管理的进程不能持久化保存，当supervisor重启后，进程就不在了，需要重新动态添加进程。