|
|
@@ -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):
|
|
|
if not feature_dict or len(feature_dict)<22:
|
|
|
@@ -228,18 +263,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']
|
|
|
@@ -253,7 +295,7 @@ def get_tf_serving_sores(feature_dict):
|
|
|
result = request_post_data(config_.TF_SERVING_URL,request_data, timeout=(0.1, 1))
|
|
|
#print("result:", result)
|
|
|
if result is None:
|
|
|
- print("result is None")
|
|
|
+ #print("result is None")
|
|
|
log_.info('call tf serving error，types: {}')
|
|
|
return []
|
|
|
#print(result)
|
linfan