debug

app.py

@@ -1,11 +1,11 @@
 import random
 import logging
-
-from gevent import monkey
-monkey.patch_all()
-
 import json
 import time
+import traceback
+import ast
+from gevent import monkey
+monkey.patch_all()
 
 from flask import Flask, request
 from log import Log
@@ -14,41 +14,27 @@ from recommend import video_homepage_recommend, video_relevant_recommend
 from category import get_category_videos
 from video_recall import PoolRecall
 from db_helper import RedisHelper
-import traceback
-import ast
 from gevent.pywsgi import WSGIServer
 from multiprocessing import cpu_count, Process
 from utils import update_video_w_h_rate
 from user2new import user2new
 from params_helper import Params
 # from werkzeug.middleware.profiler import ProfilerMiddleware
+from geventwebsocket.handler import WebSocketHandler
+
 
-# import sentry_sdk
-# from sentry_sdk.integrations.flask import FlaskIntegration
-#
-# sentry_sdk.init(
-#     dsn="https://3960f1cb8cbe49768f77efcfdbdcec50@o1288299.ingest.sentry.io/6504932",
-#     integrations=[
-#         FlaskIntegration(),
-#     ],
-#
-#     # Set traces_sample_rate to 1.0 to capture 100%
-#     # of transactions for performance monitoring.
-#     # We recommend adjusting this value in production.
-#     traces_sample_rate=1.0,
-#
-#     # By default the SDK will try to use the SENTRY_RELEASE
-#     # environment variable, or infer a git commit
-#     # SHA as release, however you may want to set
-#     # something more human-readable.
-#     # release="myapp@1.0.0",
-# )
+logging.basicConfig(level=logging.DEBUG,  # 控制台打印的日志级别
+                    filename='app.log',  # 将日志写入log_new.log文件中
+                    filemode='w',  # 模式，有w和a，w就是写模式，每次都会重新写日志，覆盖之前的日志 a是追加模式，默认如果不写的话，就是追加模式
+                    format="%(asctime)s:%(levelname)s:%(name)s -- %(message)s", datefmt="%Y/%m/%d %H:%M:%S"  # 日志格式
+                    )
 
 app = Flask(__name__)
 
 # handler = logging.FileHandler('app.log', encoding='utf-8')
 # logging_format = logging.Formatter('%(asctime)s - %(levelname)s - %(filename)s- %(funcName)s - %(lineno): %(message)s')
 # handler.setFormatter(logging_format)
+# app.logger.setLevel(logging.DEBUG)
 # app.logger.addHandler(handler)
 
 #app.wsgi_app = ProfilerMiddleware(app.wsgi_app)
@@ -295,7 +281,7 @@ def apprun(MULTI_PROCESS=True, ip='0.0.0.0', port=5001):
     if MULTI_PROCESS == False:
         WSGIServer((ip, port), app).serve_forever()
     else:
-        mulserver = WSGIServer((ip, port), app)
+        mulserver = WSGIServer((ip, port), app, handler_class=WebSocketHandler)
         mulserver.start()
  
         def server_forever():
@@ -310,7 +296,7 @@ def apprun(MULTI_PROCESS=True, ip='0.0.0.0', port=5001):
 
 if __name__ == '__main__':
     
-    #app.run()
+    # app.run(debug=True)
     #server = pywsgi.WSGIServer(('0.0.0.0', 5000), app)
     #server.serve_forever()
     apprun()