|
@@ -149,7 +149,7 @@ def h_timer_check():
|
|
|
else:
|
|
else:
|
|
|
log_.info("上游数据就绪，count={}，开始读取数据表".format(table_data_cnt))
|
|
log_.info("上游数据就绪，count={}，开始读取数据表".format(table_data_cnt))
|
|
|
# 2 读取数据表 处理特征
|
|
# 2 读取数据表 处理特征
|
|
|
- previous_date_str = datetime.strptime(date, "%Y%m%d") - timedelta(days=1).strftime("%Y%m%d")
|
|
|
|
|
|
|
+ previous_date_str = (datetime.strptime(date, "%Y%m%d") - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
video_list = get_sql(date, previous_date_str, project)
|
|
video_list = get_sql(date, previous_date_str, project)
|
|
|
# 3 写入redis
|
|
# 3 写入redis
|
|
|
log_.info("video的数据量:{}".format(len(video_list)))
|
|
log_.info("video的数据量:{}".format(len(video_list)))
|
zhangbo