add fea

rank_service.py

@@ -100,13 +100,13 @@ def get_featurs(mid, data, size, top_K, flow_pool_P, rec_recall_vid_list, env_di
                     day_share_score_list.append(float(per_video_staic[2]))
                     day_return_rate_list.append(float(per_video_staic[3]))
                     day_ctr_score_list.append(float(per_video_staic[4]))
-                    # day_view_users_list.append(int(per_video_staic[5]))
-                    # day_view_pv_list.append(int(per_video_staic[6]))
-                    # day_play_users_list.append(int(per_video_staic[7]))
-                    # day_play_pv_list.append(int(per_video_staic[8]))
-                    # day_share_users.append(int(per_video_staic[9]))
-                    # day_share_pv_list.append(int(per_video_staic[10]))
-                    # day_return_users_list.append(int(per_video_staic[11]))
+                    day_view_users_list.append(int(per_video_staic[5]))
+                    day_view_pv_list.append(int(per_video_staic[6]))
+                    day_play_users_list.append(int(per_video_staic[7]))
+                    day_play_pv_list.append(int(per_video_staic[8]))
+                    day_share_users.append(int(per_video_staic[9]))
+                    day_share_pv_list.append(int(per_video_staic[10]))
+                    day_return_users_list.append(int(per_video_staic[11]))
                 else:
                     insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_users_list,
                                               day_return_rate_list, day_return_users_list, day_rov_list,
@@ -128,6 +128,13 @@ def get_featurs(mid, data, size, top_K, flow_pool_P, rec_recall_vid_list, env_di
     hour_share_score_list =[]
     hour_return_rate_list = []
     hour_ctr_score_list = []
+    hour_play_pv_list = []
+    hour_play_users_list = []
+    hour_return_users_list = []
+    hour_share_pv_list = []
+    hour_view_pv_list = []
+    hour_view_users_list = []
+    hour_share_users = []
 
     if video_hour_static_info and len(video_hour_static_info)>0:
         for i in range(len(video_hour_static_info)):
@@ -139,18 +146,39 @@ def get_featurs(mid, data, size, top_K, flow_pool_P, rec_recall_vid_list, env_di
                     hour_share_score_list.append(float(per_hour_video_staic[2]))
                     hour_return_rate_list.append(float(per_hour_video_staic[3]))
                     hour_ctr_score_list.append(float(per_hour_video_staic[4]))
+                    hour_view_users_list.append(int(per_hour_video_staic[5]))
+                    hour_view_pv_list.append(int(per_hour_video_staic[6]))
+                    hour_play_users_list.append(int(per_hour_video_staic[7]))
+                    hour_play_pv_list.append(int(per_hour_video_staic[8]))
+                    hour_share_users.append(int(per_hour_video_staic[9]))
+                    hour_share_pv_list.append(int(per_hour_video_staic[10]))
+                    hour_return_users_list.append(int(per_hour_video_staic[11]))
                 else:
                     hour_rov_list.append(0.0)
                     hour_share_return_score_list.append(0.0)
                     hour_share_score_list.append(0.0)
                     hour_return_rate_list.append(0.0)
                     hour_ctr_score_list.append(0.0)
+                    hour_play_pv_list.append(0)
+                    hour_play_users_list.append(0)
+                    hour_return_users_list.append(0)
+                    hour_share_pv_list.append(0)
+                    hour_view_pv_list.append(0)
+                    hour_view_users_list.append(0)
+                    hour_share_users.append(0)
             except Exception:
                     hour_rov_list.append(0.0)
                     hour_share_return_score_list.append(0.0)
                     hour_share_score_list.append(0.0)
                     hour_return_rate_list.append(0.0)
                     hour_ctr_score_list.append(0.0)
+                    hour_play_pv_list.append(0)
+                    hour_play_users_list.append(0)
+                    hour_return_users_list.append(0)
+                    hour_share_pv_list.append(0)
+                    hour_view_pv_list.append(0)
+                    hour_view_users_list.append(0)
+                    hour_share_users.append(0)
     else:
         for i in range(len(rec_recall_vid_list)):
             hour_rov_list.append(0.0)
@@ -174,18 +202,25 @@ def get_featurs(mid, data, size, top_K, flow_pool_P, rec_recall_vid_list, env_di
     feature_dict["day_share_score_list"] = day_share_score_list
     feature_dict["day_return_rate_list"] = day_return_rate_list
     feature_dict["day_ctr_score_list"] = day_ctr_score_list
-    # feature_dict["day_play_pv_list"] = day_play_pv_list
-    # feature_dict["day_play_users_list"] = day_play_users_list
-    # feature_dict["day_return_users_list"] = day_return_users_list
-    # feature_dict["day_share_pv_list"] = day_share_pv_list
-    # feature_dict["day_view_pv_list"] = day_view_pv_list
-    # feature_dict["day_view_users_list"] = day_view_users_list
-    # feature_dict["day_share_users_list"] = day_share_users
+    feature_dict["day_play_pv_list"] = day_play_pv_list
+    feature_dict["day_play_users_list"] = day_play_users_list
+    feature_dict["day_return_users_list"] = day_return_users_list
+    feature_dict["day_share_pv_list"] = day_share_pv_list
+    feature_dict["day_view_pv_list"] = day_view_pv_list
+    feature_dict["day_view_users_list"] = day_view_users_list
+    feature_dict["day_share_users_list"] = day_share_users
     feature_dict["hour_rov_list"] = hour_rov_list
     feature_dict["hour_share_return_score_list"] = hour_share_return_score_list
     feature_dict["hour_share_score_list"] = hour_share_score_list
     feature_dict["hour_return_rate_list"] = hour_return_rate_list
     feature_dict["hour_ctr_score_list"] = hour_ctr_score_list
+    feature_dict["hour_play_pv_list"] = hour_play_pv_list
+    feature_dict["hour_play_users_list"] = hour_play_users_list
+    feature_dict["hour_return_users_list"] = hour_return_users_list
+    feature_dict["hour_share_pv_list"] = hour_share_pv_list
+    feature_dict["hour_view_pv_list"] = hour_view_pv_list
+    feature_dict["hour_view_users_list"] = hour_view_users_list
+    feature_dict["hour_share_users_list"] = hour_share_users
     feature_dict["city_code"] = city_list
     feature_dict["province_code"] = province_list
     feature_dict["relevant_video_id"] = relevant_video_list
@@ -200,13 +235,13 @@ def insert_static_default_fea(day_ctr_score_list, day_play_pv_list, day_play_use
     day_share_score_list.append(0.0)
     day_return_rate_list.append(0.0)
     day_ctr_score_list.append(0.0)
-    # day_view_users_list.append(0)
-    # day_view_pv_list.append(0)
-    # day_play_users_list.append(0)
-    # day_play_pv_list.append(0)
-    # day_share_users.append(0)
-    # day_share_pv_list.append(0)
-    # day_return_users_list.append(0)
+    day_view_users_list.append(0)
+    day_view_pv_list.append(0)
+    day_play_users_list.append(0)
+    day_play_pv_list.append(0)
+    day_share_users.append(0)
+    day_share_pv_list.append(0)
+    day_return_users_list.append(0)
 
 
 def get_tf_serving_sores(feature_dict):
@@ -227,18 +262,25 @@ def get_tf_serving_sores(feature_dict):
                     "day_share_score": feature_dict["day_share_score_list"],
                     "day_return_rate": feature_dict["day_return_rate_list"],
                     "day_ctr_score": feature_dict["day_ctr_score_list"],
-                    # "day_play_pv": feature_dict["day_play_pv_list"],
-                    # "day_play_users": feature_dict["day_play_users_list"],
-                    # "day_share_pv": feature_dict["day_share_pv_list"],
-                    # "day_return_users": feature_dict["day_return_users_list"],
-                    # "day_share_users": feature_dict["day_share_users_list"],
-                    # "day_view_pv": feature_dict["day_view_pv_list"],
-                    # "day_view_users":feature_dict["day_view_users_list"],
+                    "day_play_pv": feature_dict["day_play_pv_list"],
+                    "day_play_users": feature_dict["day_play_users_list"],
+                    "day_share_pv": feature_dict["day_share_pv_list"],
+                    "day_return_users": feature_dict["day_return_users_list"],
+                    "day_share_users": feature_dict["day_share_users_list"],
+                    "day_view_pv": feature_dict["day_view_pv_list"],
+                    "day_view_users":feature_dict["day_view_users_list"],
                     "hour_rov": feature_dict["hour_rov_list"],
                     "hour_share_score": feature_dict["hour_share_score_list"],
-                    #"hour_share_return_score": feature_dict["hour_share_return_score_list"],
-                    #"hour_return_rate": feature_dict["hour_return_rate_list"],
-                    #"hour_ctr_score": feature_dict["hour_ctr_score_list"],
+                    "hour_share_return_score": feature_dict["hour_share_return_score_list"],
+                    "hour_return_rate": feature_dict["hour_return_rate_list"],
+                    "hour_ctr_score": feature_dict["hour_ctr_score_list"],
+                    "hour_play_pv": feature_dict["hour_play_pv_list"],
+                    "hour_play_users": feature_dict["hour_play_users_list"],
+                    "hour_share_pv": feature_dict["hour_share_pv_list"],
+                    "hour_return_users": feature_dict["hour_return_users_list"],
+                    "hour_share_users": feature_dict["hour_share_users_list"],
+                    "hour_view_pv": feature_dict["hour_view_pv_list"],
+                    "hour_view_users": feature_dict["hour_view_users_list"],
                     "city_code": feature_dict['city_code'],
                     "province_code": feature_dict['province_code'],
                     "relevant_video_id":feature_dict['relevant_video_id']
@@ -247,7 +289,7 @@ def get_tf_serving_sores(feature_dict):
     request_data_dict["inputs"] = inputs_data
     #print(request_data_dict)
     request_data= json.dumps(request_data_dict)
-    #print(request_data)
+    print(request_data)
     # 调用http接口
     result = request_post_data(config_.TF_SERVING_URL,request_data, timeout=(0.1, 1))
     #print("result:", result)