代码拉取完成，页面将自动刷新
Flask-Restful+Migrate+JWT+Redis+celery+APScheduler综合后端API服务器案例
$ python -m venv venv
# 激活虚拟环境
# Linux
$ source venv/bin/activate
# Windows
$ venv\Scripts\activate
# 安装相关依赖包
$ pip install -r requirements.txt
Linux 和 macOS 用户这样做：
(venv) $ export FLASK_APP=run.py
(venv) $ export FLASK_DEBUG=1
微软 Windows 用户这样做：
(venv) $ set FLASK_APP=run.py
(venv) $ set FLASK_DEBUG=1
创建数据
(venv) $ flask db init
(venv) $ flask db migrate
(venv) $ flask db upgrade
初始化数据库命令
# 此命令会删除数据重新创建数据库
(venv) $ flask initdb --drop
This operation will delete the database, do you want to continue? [y/N]: y
INSERT INTO `todo` VALUES (1, '白鹿原', '这是一定死啦塞啊；阿凯骄傲灵丹安矿鉴定暗访东方三；啊反馈；安静快撒娇扥卡机', 0);
INSERT INTO `todo` VALUES (2, '嫌疑人', 'as大肯借；额看课文静安寺放大反抗航将；来否；付定金奥兰多 看企鹅长恨东澳岛啊；伐开森', 0);
(venv) $ set FLASK_APP=run.py
(venv) $ set FLASK_DEBUG=1
(venv) $ flask run -h 0.0.0.0 -p 5000
* Serving Flask app 'run.py'
* Debug mode: on
WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead.
* Running on all addresses (0.0.0.0)
* Running on http://127.0.0.1:5000
* Running on http://172.16.3.134:5000
Press CTRL+C to quit
* Restarting with stat
* Debugger is active!
* Debugger PIN: 170-478-610
注册用户
curl --request POST \
--url http://localhost:5000/api/v1.0/register \
--header 'Content-Type: application/json' \
--data '{"email": "2@2.com","username":"hjl2","password":"123456"}'
用户登录
curl --request POST \
--url http://localhost:5000/api/v1.0/login \
--data '{"username": "hjl1","password": "123456"}'
查看所有用户
curl -i http://localhost:5000/api/v1.0/users \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgwNzY5LCJqdGkiOiI4Y2JhMDRmMS1kOTRhLTQ0MWQtOWM5My01OTFhNzlhMjI4YWYiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MDc2OSwiZXhwIjoxNjYzNTgxNjY5fQ.1GvPqgtNNOQ95HRFiLwAbeU9-BUU5uJniw0jAz6QLAs' \
--header 'Content-Type: application/json'
查看单个用户
curl -i http://localhost:5000/api/v1.0/user/1 \
-H 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgwNzY5LCJqdGkiOiI4Y2JhMDRmMS1kOTRhLTQ0MWQtOWM5My01OTFhNzlhMjI4YWYiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MDc2OSwiZXhwIjoxNjYzNTgxNjY5fQ.1GvPqgtNNOQ95HRFiLwAbeU9-BUU5uJniw0jAz6QLAs' \
-H 'Content-Type: application/json'
更新单个用户
curl -i -H "Content-Type: application/json" \
-H 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgwNzY5LCJqdGkiOiI4Y2JhMDRmMS1kOTRhLTQ0MWQtOWM5My01OTFhNzlhMjI4YWYiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MDc2OSwiZXhwIjoxNjYzNTgxNjY5fQ.1GvPqgtNNOQ95HRFiLwAbeU9-BUU5uJniw0jAz6QLAs' \
-X PUT -d '{"username": "hjl1"}' \
http://localhost:5000/api/v1.0/user/1
删除单个用户
curl --request DELETE \
--url http://localhost:5000/api/v1.0/user/2 \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgwNzY5LCJqdGkiOiI4Y2JhMDRmMS1kOTRhLTQ0MWQtOWM5My01OTFhNzlhMjI4YWYiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MDc2OSwiZXhwIjoxNjYzNTgxNjY5fQ.1GvPqgtNNOQ95HRFiLwAbeU9-BUU5uJniw0jAz6QLAs' \
--header 'Content-Type: application/json'
刷新token
curl --request POST \
--url http://localhost:5000/api/v1.0/token/refresh \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6ZmFsc2UsImlhdCI6MTY2MzU4MDc2OSwianRpIjoiMzMyNTkyODYtNWY1NS00MzlmLTg2ZDktYWMyODRjZjA2YjMxIiwidHlwZSI6InJlZnJlc2giLCJzdWIiOiJoamwxIiwibmJmIjoxNjYzNTgwNzY5LCJleHAiOjE2NjYxNzI3Njl9.BaMmLRu6H-PjBN4MjWymnB0wlTeioMev4wD_34S5Yd8' \
--header 'Content-Type: application/json'
用户注销登录
curl --request POST \
--url http://localhost:5000/api/v1.0//logout/access \
--header 'Accept: */*' \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6ZmFsc2UsImlhdCI6MTY2MzU4MTU1OCwianRpIjoiOTJiMzllOWMtMjg4OS00NTc0LThlYTQtZmIwMTFiMzJiNWU3IiwidHlwZSI6ImFjY2VzcyIsInN1YiI6ImhqbDEiLCJuYmYiOjE2NjM1ODE1NTgsImV4cCI6MTY2MzU4MjQ1OH0.Hfd4uovp6nDVLqQKDtrNk_ncSWPt7wjR2qFazDWfwuY' \
--header 'Content-Type: application/json'
用户注销刷新
curl --request POST \
--url http://localhost:5000/api/v1.0//logout/refresh \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6ZmFsc2UsImlhdCI6MTY2MzU4MDc2OSwianRpIjoiMzMyNTkyODYtNWY1NS00MzlmLTg2ZDktYWMyODRjZjA2YjMxIiwidHlwZSI6InJlZnJlc2giLCJzdWIiOiJoamwxIiwibmJmIjoxNjYzNTgwNzY5LCJleHAiOjE2NjYxNzI3Njl9.BaMmLRu6H-PjBN4MjWymnB0wlTeioMev4wD_34S5Yd8' \
--header 'Content-Type: application/json'
| 接口 | API地址 |
|---|---|
| 查看所有任务 | http://localhost:5000/api/v1.0/tasks |
| 新增单个任务 | http://localhost:5000/api/v1.0/tasks |
| 查看单个任务 | http://localhost:5000/api/v1.0/tasks/3 |
| 更新单个任务 | http://localhost:5000/api/v1.0/tasks/3 |
| 删除单个任务 | http://localhost:5000/api/v1.0/tasks/3 |
查看所有任务
curl --request GET \
--url http://localhost:5000/api/v1.0/tasks \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgyNDY3LCJqdGkiOiIyYWQ2NGIyNC03OGFkLTQ2OTQtYWRjZS1hNmZhYjExYzYxNzEiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MjQ2NywiZXhwIjoxNjYzNTgzMzY3fQ.tLwVHfBO91JNlBskqBfKzzWh2xf_GKyHGsddjoQ7VIw' \
--header 'Content-Type: application/json'
新增单个任务
curl --request POST \
--url http://localhost:5000/api/v1.0/tasks \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgyNDY3LCJqdGkiOiIyYWQ2NGIyNC03OGFkLTQ2OTQtYWRjZS1hNmZhYjExYzYxNzEiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MjQ2NywiZXhwIjoxNjYzNTgzMzY3fQ.tLwVHfBO91JNlBskqBfKzzWh2xf_GKyHGsddjoQ7VIw' \
--header 'Content-Type: application/json' \
--data '{"title": "阿里巴巴和四十大盗"}'
查看单个任务
curl --request GET \
--url http://localhost:5000/api/v1.0/tasks/3 \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgyNDY3LCJqdGkiOiIyYWQ2NGIyNC03OGFkLTQ2OTQtYWRjZS1hNmZhYjExYzYxNzEiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MjQ2NywiZXhwIjoxNjYzNTgzMzY3fQ.tLwVHfBO91JNlBskqBfKzzWh2xf_GKyHGsddjoQ7VIw' \
--header 'Content-Type: application/json'
更新单个任务
curl --request PUT \
--url http://localhost:5000/api/v1.0/tasks/3 \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgyNDY3LCJqdGkiOiIyYWQ2NGIyNC03OGFkLTQ2OTQtYWRjZS1hNmZhYjExYzYxNzEiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MjQ2NywiZXhwIjoxNjYzNTgzMzY3fQ.tLwVHfBO91JNlBskqBfKzzWh2xf_GKyHGsddjoQ7VIw' \
--header 'Content-Type: application/json'
--data '{ "description": "一千零一夜故事里面的篇幅"}'
删除单个任务
curl --request DELETE \
--url http://localhost:5000/api/v1.0/tasks/3 \
--header 'Authorization: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJmcmVzaCI6dHJ1ZSwiaWF0IjoxNjYzNTgyNDY3LCJqdGkiOiIyYWQ2NGIyNC03OGFkLTQ2OTQtYWRjZS1hNmZhYjExYzYxNzEiLCJ0eXBlIjoiYWNjZXNzIiwic3ViIjoiaGpsMSIsIm5iZiI6MTY2MzU4MjQ2NywiZXhwIjoxNjYzNTgzMzY3fQ.tLwVHfBO91JNlBskqBfKzzWh2xf_GKyHGsddjoQ7VIw' \
--header 'Content-Type: application/json'
| 接口 | API地址 |
|---|---|
| redis写入数据 | http://localhost:5000/api/testRedisWrite |
| redis读取数据 | http://localhost:5000/api/testRedisRead |
写入数据redis数据库
curl --request GET \
--url http://localhost:5000/api/v1.0/testRedisWrite
读取redis数据
curl --request GET \
--url http://localhost:5000/api/v1.0/testRedisRead
| 接口 | API地址 |
|---|---|
| 测试相加-task | http://localhost:5000/api/testAdd |
| 测试获取flask上下文-task | http://localhost:5000/api/testFlaskAppContext |
windows shell中输入
celery -A run:celery_app worker --pool=solo -l info
Linux shell中输入
celery -A run:celery_app worker -l info
启动Flask APP
(venv) $ flask run -h 0.0.0.0 -p 5000
参考文献：
主要解决了新版本的Celery使用Flask上下文的功能 https://www.qinzhiqiang.xyz/article/19
本demo使用的就是flask-jwt-extended插件
https://xugaoxiang.com/2020/09/01/flask-18-jwt-extended/ https://www.jianshu.com/p/c155c2b7af42 https://www.cnblogs.com/WiseAdministrator/articles/11734600.html
官方文档
新版本的flask-jwt-extended，已经改了很多的API了， 参考: https://flask-jwt-extended.readthedocs.io/en/stable/v4_upgrade_guide/#api-changes
https://www.qinzhiqiang.xyz/article/11
APScheduler
APScheduler的全称是Advanced Python Scheduler。 它是一个轻量级的 Python 定时任务调度框架。 APScheduler 支持三种调度任务：固定时间间隔，固定时间点（日期），Linux 下的 Crontab 命令。 同时，它还支持异步执行、后台执行调度任务。
APScheduler操作数据库
app/tasks/scheduler_task.py
# task.py中使用数据库
def db_query_todo_all():
"""
定时任务使用数据库
"""
# 一定是要导入scheduler，这个是带有app及其上下文的，如果直接用current_app替代scheduler.app使用上下文
with scheduler.app.app_context():
data = db.session.query(Users).first()
print(data.username)
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。