|
|
@@ -206,7 +206,7 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
|
|
|
score = day_recall_df[day_recall_df['videoid'] == video_id]['score']
|
|
|
day_recall_result[int(video_id)] = float(score)
|
|
|
day_video_ids.append(int(video_id))
|
|
|
- json_data.append({'videoId': video_id, 'rovScore': score})
|
|
|
+ json_data.append({'videoId': video_id, 'rovScore': float(score)})
|
|
|
|
|
|
h_24h_recall_key_name = \
|
|
|
f"{config_.RECALL_KEY_NAME_PREFIX_BY_24H}{data_key}:{rule_key}:{now_dt}:{now_h}"
|
|
|
@@ -220,6 +220,7 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
|
|
|
# 通知后端更新兜底视频数据
|
|
|
if notify_backend is True:
|
|
|
log_.info('json_data count = {}'.format(len(json_data)))
|
|
|
+ # log_.info(f"json_data = {json_data}")
|
|
|
result = request_post(request_url=config_.NOTIFY_BACKEND_updateFallBackVideoList_URL,
|
|
|
request_data={'videos': json_data})
|
|
|
if result is None:
|
