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配置的一些参数。
效果:
不过supervisor_twiddler管理的进程不能持久化保存,当supervisor重启后,进程就不在了,需要重新动态添加进程。