Fastapi 安装部署
Fastapi 安装部署
Categories:
Fastapi 安装部署
环境基础安装
pip install fastapi uvicorn gunicorn supervisor
简单Fastapi代码
1
2import uvicorn
3from loguru import logger
4import arrow
5import pymysql
6import sys
7
8from fastapi import FastAPI, Query, Request, Body
9from pydantic import BaseModel
10from fastapi.encoders import jsonable_encoder
11from fastapi.responses import JSONResponse
12from typing import List, Tuple, Set
13
14
15app = FastAPI(title='订单同步接口', description='订单同步接口')
16
17if "win" in sys.platform:
18 logger.add("./db.log", encoding='utf-8')
19else:
20 logger.add("/path/db.log", encoding='utf-8')
21
22
23curnow = arrow.now()
24nowhour = curnow.format("YYYY-MM-DD HH:mm:ss")
25before3hour = curnow.shift(hours=-3).format("YYYY-MM-DD HH:mm:ss")
26
27
28class Argcls(BaseModel):
29 begintime: str = before3hour
30 endtime: str = nowhour
31 orders: List[str] = []
32
33class DB:
34
35 def __init__(self):
36 try:
37 if "win" in sys.platform:
38 self.db = pymysql.connect(host="127.0.0.1", port=3306, user="root", password="root", db="dbname", charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
39 else:
40 self.db = pymysql.connect(host="127.0.0.1", port=3306, user="root", password="root", db="dbname", charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
41 except:
42 logger.error("数据库连接失败!")
43 self.cur = self.db.cursor()
44
45 def query(self, sql):
46 self.cur.execute(sql)
47 return self.cur.fetchall()
48
49 def __del__(self):
50 self.cur.close()
51 self.db.close()
52
53
54
55sql_order = """ select * from user_order where states>0 and %s """
56
57sql_order_subs = """ SELECT * FROM user_order_subs WHERE orders_id='%s'"""
58
59@app.post('/getOrder', summary='指定时间范围内的订单', description='查询指定时间范围内的订单')
60def seach_order(args: Argcls = Body(..., example={"begintime": "查询订单的开始时间 eg 2022-03-04 00:00:00",
61 "endtime": "查询订单的结束时间 eg 2022-03-04 23:59:59",
62 "orders": "List[orderid字符串]"})):
63
64 logger.info("查询参数 {}", args)
65
66 wherestr = "create_time>='%s' and create_time<='%s'" % (args.begintime, args.endtime)
67 if len(args.orders):
68 orderstr = " orders_codes in ('%s')" % "','".join(args.orders)
69 wherestr = "( (%s) or %s)" % (wherestr, orderstr)
70
71 sql = sql_order % (wherestr)
72 logger.info("查询语句 {}", sql)
73
74 db = DB()
75
76 res = db.query(sql)
77 for key, row in enumerate(res):
78 res[key]['sub_orders'] = db.query(sql_order_subs % (row['id']))
79
80 logger.info("返回条数 {}", len(res))
81 return res
82
83
84if __name__ == '__main__':
85 logger.info("启动运行...")
86 uvicorn.run(app='main:app', host="0.0.0.0", port=7296, reload=True, debug=True)
运行代码
# 命令行运行测试
python main.py
# 使用 uvicron 运行
uvicorn main:app --reload --host 0.0.0.0 --port 7296
# 使用 gunicorn 运行
gunicorn main:app -b 0.0.0.0:7296 -w 4 -k uvicorn.workers.UvicornWorker --daemon
Gunicorn 已配置文件方式启动
* 以配置文件的方式启动
gunicorn.conf
import multiprocessing
# 并行工作进程数(multiprocessing.cpu_count()线程数,官方说可以有：核心数*2+1个)
workers = multiprocessing.cpu_count() * 2 + 1
# 指定每个工作者的线程数
threads = 2
# 监听内网端口5000
bind = '127.0.0.1:5000'
# 设置守护进程,推荐将进程交给supervisor管理(以守护进程形式来运行Gunicorn进程，true其实就是将这个服务放到后台去运行,故此处设置false，交给supervisor开守护进程，因为supervisor不支持后台进程)
daemon = 'false'
# 工作模式协程
worker_class = 'gevent'
# 设置最大并发量
worker_connections = 2000
# 设置进程文件目录
pidfile = '/var/run/gunicorn.pid'
# 设置访问日志和错误信息日志路径
accesslog = '/var/log/gunicorn_acess.log'
errorlog = '/var/log/gunicorn_error.log'
# 日志级别，这个日志级别指的是错误日志的级别，而访问日志的级别无法设置
loglevel = 'warning'
# 启动unicorn
gunicorn -c gunicorn.conf main:app
# 获取Gunicorn进程树
pstree -ap|grep gunicorn
# 重启Gunicorn任务
kill -HUP 30080
Supervisor 配置运行
pip install supervisor
默认配置文件：/etc/supervisord.conf
进程管理配置文件放到：/etc/supervisord.d/目录下即可
mkdir -p ~/etc/supervisor/conf.d
mkdir -p ~/etc/supervisor/var/log
cd ~/etc
echo_supervisord_conf > supervisord.conf
* 修改 supervisor.conf，让 Supervisor 进程产生的一些文件生成到上面我们创建的目录下，而不是其默认指定的地方。
* 首先找到 [unix_http_server] 版块，将 file 设置改为如下的值，即让 socket 文件生成在 ~/etc/supervisor/var/ 目录下。
注意 supervisor 不支持将 ~ 展开为用户 home 目录，所以要用绝对路径指定。：
* [unix_http_server]file=/root/etc/supervisor/var/supervisor.sock
* 类似的修改 [supervisord] 板块下的 logfile 和 pidfile 文件的路径，还有 user 改为系统用户，这样 supervisor 启动的进程将以系统用户运行，避免可能的权限问题：
*
[supervisord]logfile= /root/etc/supervisor/var/log/supervisord.log
pidfile=/root/etc/supervisor/var/supervisord.pid
user=root
* [supervisorctl] 板块下：
* [supervisorctl]serverurl=unix:///root/etc/supervisor/var/supervisor.sock
* [include] 版块，将 /home/yangxg/etc/supervisor/conf.d/ 目录下所有以 .ini 结尾的文件内容包含到配置中来，
这样便于配置的模块化管理，和之前 Nginx 配置文件的处理方式是类似的。
* [include]files = /root/etc/supervisor/conf.d/*.ini
* 然后我们到 conf.d 新建应用的配置
(py3.6) [root@iZbp11gqesu0znu7pkmgp7Z conf.d]# cat fig1.ini
[program:api-fastapi]
command=gunicorn main:app -w 4 -k uvicorn.workers.UvicornWorker --timeout 30 -b 0.0.0.0:8000
directory=/root/api-fastapi/
autostart=true
autorestart=unexpected
user=root
stdout_logfile=/etc/supervisor/var/log/api-fastapi-stdout.log
stderr_logfile=/etc/supervisor/var/log/api-fastapi-stderr.log
各项配置的含义：
[program:wenda_slmx] 指明运行应用的进程，名为 wenda_slmx。
command 为进程启动时执行的命令。
directory 指定执行命令时所在的目录。
autostart 随 Supervisor 启动自动启动进程。
autorestart 进程意外退出时重启。
user 进程运行的用户，防止权限问题。
stdout_logfile，stderr_logfile 日志输出文件。
* 启动 Supervisor
supervisord -c ~/etc/supervisord.conf
* -c 指定 Supervisr 启动时的配置文件。
* 更新新的配置到supervisord
* supervisorctl update
* 重新启动配置中的所有程序
* supervisorctl reload
* 浏览器输入域名，可以看到服务已经正常启动了。
[unix_http_server]
file=/tmp/supervisor.sock ;UNIX socket 文件，supervisorctl 会使用
;chmod=0700 ;socket文件的mode，默认是0700;chown=nobody:nogroup ;socket文件的owner，格式：uid:gid
;[inet_http_server] ;HTTP服务器，提供web管理界面
;port=127.0.0.1:9001 ;Web管理后台运行的IP和端口，如果开放到公网，需要注意安全性
;username=user ;登录管理后台的用户名
;password=123 ;登录管理后台的密码
[supervisord]
logfile=/tmp/supervisord.log ;日志文件，默认是 $CWD/supervisord.log
logfile_maxbytes=50MB ;日志文件大小，超出会rotate，默认 50MB，如果设成0，表示不限制大小
logfile_backups=10 ;日志文件保留备份数量默认10，设为0表示不备份
loglevel=info ;日志级别，默认info，其它: debug,warn,trace
pidfile=/tmp/supervisord.pid ;pid 文件
nodaemon=false ;是否在前台启动，默认是false，即以 daemon 的方式启动
minfds=1024 ;可以打开的文件描述符的最小值，默认 1024
minprocs=200 ;可以打开的进程数的最小值，默认 200
[supervisorctl]
serverurl=unix:///tmp/supervisor.sock ;通过UNIX socket连接supervisord，路径与unix_http_server部分的file一致;serverurl=http://127.0.0.1:9001 ; 通过HTTP的方式连接supervisord
; [program:xx]是被管理的进程配置参数，xx是进程的名称
[program:xx]
command=/opt/apache-tomcat-8.0.35/bin/catalina.sh run ; 程序启动命令
autostart=true ; 在supervisord启动的时候也自动启动
startsecs=10 ; 启动10秒后没有异常退出，就表示进程正常启动了，默认为1秒
autorestart=true ; 程序退出后自动重启,可选值：[unexpected,true,false]，默认为unexpected，表示进程意外杀死后才重启
startretries=3 ; 启动失败自动重试次数，默认是3
user=tomcat ; 用哪个用户启动进程，默认是root
priority=999 ; 进程启动优先级，默认999，值小的优先启动
redirect_stderr=true ; 把stderr重定向到stdout，默认false
stdout_logfile_maxbytes=20MB ; stdout 日志文件大小，默认50MB
stdout_logfile_backups = 20 ; stdout 日志文件备份数，默认是10; stdout 日志文件，需要注意当指定目录不存在时无法正常启动，所以需要手动创建目录（supervisord 会自动创建日志文件）
stdout_logfile=/opt/apache-tomcat-8.0.35/logs/catalina.out
stopasgroup=false ;默认为false,进程被杀死时，是否向这个进程组发送stop信号，包括子进程
killasgroup=false ;默认为false，向进程组发送kill信号，包括子进程
;包含其它配置文件
[include]
files = relative/directory/*.ini ;可以指定一个或多个以.ini结束的配置文件
子进程配置文件说明：
给需要管理的子进程(程序)编写一个配置文件，放在/etc/supervisor.d/目录下，以.ini作为扩展名（每个进程的配置文件都可以单独分拆也可以把相关的脚本放一起）。如任意定义一个和脚本相关的项目名称的选项组
#项目名[program:blog]#脚本目录
directory=/opt/bin
#脚本执行命令
command=/usr/bin/python /opt/bin/test.py
#supervisor启动的时候是否随着同时启动，默认True
autostart=true#当程序exit的时候，这个program不会自动重启,默认unexpected，设置子进程挂掉后自动重启的情况，有三个选项，false,unexpected和true。如果为false的时候，无论什么情况下，都不会被重新启动，如果为unexpected，只有当进程的退出码不在下面的exitcodes里面定义的
autorestart=false#这个选项是子进程启动多少秒之后，此时状态如果是running，则我们认为启动成功了。默认值为1
startsecs=1
#脚本运行的用户身份
user = test
#日志输出
stderr_logfile=/tmp/blog_stderr.log
stdout_logfile=/tmp/blog_stdout.log
#把stderr重定向到stdout，默认 false
redirect_stderr = true#stdout日志文件大小，默认 50MB
stdout_logfile_maxbytes = 20MB
#stdout日志文件备份数
stdout_logfile_backups = 20
子进程配置示例：
#说明同上
[program:test]
directory=/opt/bin
command=/opt/bin/test
autostart=true
autorestart=false
stderr_logfile=/tmp/test_stderr.log
stdout_logfile=/tmp/test_stdout.log
#user = test
supervisorctl status //查看所有进程的状态
supervisorctl stop es //停止es
supervisorctl start es //启动es
supervisorctl restart //重启es
supervisorctl update //配置文件修改后使用该命令加载新的配置
supervisorctl reload //重新启动配置中的所有程序
新建文件supervisord.service
#supervisord.service
[Unit]
Description=Supervisor daemon
[Service]
Type=forking
ExecStart=/usr/bin/supervisord -c /etc/supervisord.conf
ExecStop=/usr/bin/supervisorctl shutdown
ExecReload=/usr/bin/supervisorctl reload
KillMode=process
Restart=on-failure
RestartSec=42s
[Install]
WantedBy=multi-user.target
------------------------------------------
cp supervisord.service /usr/lib/systemd/system/
启动服务
systemctl enable supervisord
验证一下是否为开机启动
systemctl is-enabled supervisord