获取 rov 数据

data_process/update_mysql_data.py

@@ -57,8 +57,8 @@ class DataProcessor(object):
             label_dt = generate_label_date(hourly_dt_str)
             label_obj = label_info.get(label_dt, {}).get(video_id)
             if label_obj:
-                total_return = label_obj.get('flowpool_return_users', 0)
-                total_view = label_obj.get('flowpool_distribute_view_times', 0)
+                total_return = label_obj.get('total_return', 0)
+                total_view = label_obj.get('total_view', 0)
                 if total_view == 0:
                     label = None
                 else: