Merge branch 'dev_david' of anweiguo/algorithm_platform into dev_awg

data_processing/data_operation/data_nwp_ftp.py

@@ -198,7 +198,10 @@ def get_nwp_from_ftp():
     args = {}
     # print("data_nwp_ftp starts execution!")
     try:
+        now = datetime.datetime.now(pytz.utc).astimezone(timezone("Asia/Shanghai")).strftime('%Y-%m-%d %H:%M:%S')
         args = request.values.to_dict()
+        if args.get('dt') is None:
+            args['dt'] = now
         # 1. 获取参数：日期，数据源，时刻，D0-9，场站ID，存储的 mongo 和表
         # print('args', args)
         logger.info(args)