分析代码

read_data_from_odps.py

@@ -127,7 +127,7 @@ def download_hour_video_data(date_str):
     L = []
     for obj in data_list:
         L.append(obj)
-    temp_path = "data/{}.json".format(date_str)
+    temp_path = "data/temp_data/hour_{}.json".format(date_str)
     with open(temp_path, "w") as f:
         f.write(json.dumps(L, ensure_ascii=False))
 
@@ -165,7 +165,7 @@ if __name__ == "__main__":
     elif flag == 2:
         start = str(input("请输入开始字符串， 格式为 yyyymmdd:\n"))
         end = str(input("请输入结束字符串, 格式为 yymmdd: \n"))
-        save_p = "data/daily-label-{}-{}.json".format(start, end)
+        save_p = "data/train_data/daily-label-{}-{}.json".format(start, end)
         if len(start) == 8 and len(end) == 8:
             save_daily_data(start, end, save_p)
         else: