Преглед на файлове

1.修改获取hive时刻与修改曦谋特征字段wd10

anweiguo преди 1 седмица
родител
ревизия
cad9e84f5b
променени са 2 файла, в които са добавени 10 реда и са изтрити 6 реда
  1. 2 2
      common/database.toml
  2. 8 4
      common/database_dml.py

+ 2 - 2
common/database.toml

@@ -8,8 +8,8 @@ password = ""
 jar_file = 'jar/hive-jdbc-standalone.jar'
 
 [xmo]
-features = ['stationCode', 'date_time', 'forecastDatatime', 'rh',  'wd80', 'ws10', 'ws80', 'dniCalcd','rain', 'dewPoint2m', 'snowfall', 'windDirection10m', 'precipitation',
+features = ['stationCode', 'date_time', 'forecastDatatime', 'rh',  'wd80', 'ws10', 'ws80', 'dniCalcd','rain', 'dewPoint2m', 'snowfall', 'wd10', 'precipitation',
            'apparentTemperature', 'weatherCode', 'sunshineDuration','shortwaveRadiation', 'directRadiation', 'diffuseRadiation','globalTiltedIrradiance', 'terrestrialRadiation']
 
-numeric_features = ['rh',  'wd80', 'ws10', 'ws80', 'dniCalcd','rain', 'dewPoint2m', 'snowfall', 'windDirection10m', 'precipitation',
+numeric_features = ['rh',  'wd80', 'ws10', 'ws80', 'dniCalcd','rain', 'dewPoint2m', 'snowfall', 'wd10', 'precipitation',
            'apparentTemperature', 'weatherCode', 'sunshineDuration','shortwaveRadiation', 'directRadiation', 'diffuseRadiation','globalTiltedIrradiance', 'terrestrialRadiation']

+ 8 - 4
common/database_dml.py

@@ -754,14 +754,18 @@ def get_xmo_data_from_hive(args):
             moment = args['moment']
         else:
             hour = datetime.strptime(args['current_date'], "%Y%m%d%H").hour
-            if hour < 3:
+            if hour < 4:
                 moment = '00'
-            elif hour < 6:
+            elif hour < 7:
                 moment = '03'
-            elif hour < 15:
+            elif hour < 10:
+                moment = '06'
+            elif hour < 13:
                 moment = '09'
-            elif hour < 19:
+            elif hour < 16:
                 moment = '12'
+            elif hour < 19:
+                moment = '15'
             else:
                 moment = '18'
             print(moment)