Browse Source

Merge branch 'debug' into dev

liqian 2 years ago
parent
commit
b4946761be
2 changed files with 16 additions and 1 deletions
  1. 9 0
      app.py
  2. 7 1
      utils.py

+ 9 - 0
app.py

@@ -1,3 +1,5 @@
+import random
+
 from gevent import monkey
 monkey.patch_all()
 
@@ -36,13 +38,17 @@ def health_check():
 @app.route('/applet/video/homepage/recommend', methods=['GET', 'POST'])
 def homepage_recommend():
     start_time = time.time()
+    in_homepage = start_time + random.randint(0, 100)
+    log_.info({"in_homepage": in_homepage})
     try:
+        log_.info({'request_headers': request.headers})
         request_data = json.loads(request.get_data())
         request_id = request_data.get('requestId')
         log_.info({
             'logTimestamp': int(time.time() * 1000),
             'request_id': request_id,
             'text': 'in homepage_recommend',
+            "in_homepage": in_homepage,
             'executeTime': (time.time() - start_time) * 1000
         })
         mid = request_data.get('mid')
@@ -102,12 +108,15 @@ def homepage_recommend():
 @app.route('/applet/video/relevant/recommend', methods=['GET', 'POST'])
 def relevant_recommend():
     start_time = time.time()
+    in_relevant = start_time + random.randint(0, 100)
+    log_.info({"in_relevant": in_relevant})
     try:
         request_data = json.loads(request.get_data())
         request_id = request_data.get('requestId')
         log_.info({
             'logTimestamp': int(time.time() * 1000),
             'request_id': request_id,
+            "in_relevant": in_relevant,
             'text': 'in relevant_recommend',
             'executeTime': (time.time() - start_time) * 1000
         })

+ 7 - 1
utils.py

@@ -384,4 +384,10 @@ if __name__ == '__main__':
     # text = '测试 @李倩'
     # send_msg_to_feishu(text)
 
-    update_video_w_h_rate(video_id=113, key_name='')
+    # update_video_w_h_rate(video_id=113, key_name='')
+
+    request_url = "http://videotest-internal.yishihui.com/longvideoapi/dev/test/testTimeout"
+    headers = {"Connection": "close"}
+    response = requests.post(url=request_url, json={}, timeout=(0.1, 1), headers=headers)
+    print(response.status_code, response.text)
+