flask、redis、进程间的通信-示例程序

flask、redis、进程间的通信-示例程序

功能

flask通过redis与进程间进行数据交换

技术栈

  1. flask(轻量级python web框架):接口路由框架
  2. redis(高性能key-value数据库):数据库缓存
  3. multiprocessing(多进程处理库):多进程
  4. Apifox:接口调试工具

流程

  1. Apifox发起http请求;
  2. flask接收http请求数据信息;
  3. 信息存入redis数据库中;
  4. 进程中读取redis数据实现打印;在这里插入代码片

CODE

#flask接口路由
@app.route("/upload", methods=['POST'])
def upload():
    try:
        msg = request.json['msg']
        r.set('uploadMsg', msg)
        msg = 'success'
    except:
        msg = 'fail'
    return jsonify({'code': 1, 'msg': msg})
# 多进程处理
def downLoad():
    while True:
        time.sleep(2)
        try:
            msg = r.get('uploadMsg')
            prt_time(msg)
        except:
            print("error!")
            
if __name__ == '__main__':
    processes = [mp.Process(target=downLoad)]
    [process.start() for process in processes]

结果

在这里插入图片描述


版权声明:本文为cike0cop原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。