12311218

data_processing/data_operation/data_nwp_ftp.py

@@ -136,6 +136,7 @@ def select_file_to_mongo(args):
                 csv_file_path = os.path.join(target_dir_path, file_name)
                 if fnmatch.fnmatch(file_name, csv_file_weather):
                     csv_weather_path = csv_file_path
+                    logger.info("找到nwp:{}".format(csv_power_path))
                 if fnmatch.fnmatch(file_name, csv_file_power):
                     csv_power_path = csv_file_path
             if csv_weather_path or csv_power_path:
@@ -184,7 +185,7 @@ ftp_params = {
         'user' : 'jiayue',
         'password' : 'JYoguf2018',
         'remote_dir' : './',
-        'local_dir': './data_processing/cache/data/xxl'
+        'local_dir': 'data_processing/cache/data/xxl'
     }
 }