我正在尝试在Flask中创建一个REST API。问题是它可以完美运行几天,然后突然完全停止接收请求。忘了不响应请求;它只是一开始没有收到任何请求。这是我的脚本:
from flask import Flask, jsonify from flask_restful import Resource, Api from flask_restful import reqparse from sqlalchemy import create_engine from flask.ext.httpauth import HTTPBasicAuth from flask.ext.cors import CORS conn_string = "mssql+pyodbc://x" e = create_engine(conn_string) auth = HTTPBasicAuth() @auth.get_password def get_password(username): if username == 'x': return 'x' return None app = Flask(__name__) cors = CORS(app) api = Api(app) class Report(Resource): decorators = [auth.login_required] def get(self): parser = reqparse.RequestParser() parser.add_argument('start', type = str) parser.add_argument('end', type = str) args = parser.parse_args() conn = e.connect() stat = """ select a, b from report where c < ? and d > ? """ query = conn.execute(stat, [args['start'], args['end']]) json_dict = [] for i in query.cursor.fetchall(): res = {'aa': i[0], 'bb':i[1]} json_dict.append(res) conn.close() return jsonify(results=json_dict) api.add_resource(Report, '/report') if __name__ == '__main__': app.run(host='0.0.0.0')
我尝试调试该问题,以下是我的观察结果:
1)Flask API在端口5000上运行,当我在端口5000上psing VM时,我能够连接,这意味着该进程实际上在VM上正常运行。
2)在检查我的日志时,API甚至没有收到GET请求。如果有一些数据库错误,那么我会收到一条500错误消息,但是请求甚至一开始都没有到达API。
3)如果我在本地调用API,则问题仍然存在。
4)如果我对端口5000(运行我的flask API的端口)执行netstat,则会得到以下信息:
由于某种原因,我认为它没有关闭套接字连接。我收到很多“ CLOSE_WAIT”。这是引起问题的原因吗?如何在代码中解决此问题?