添加导入其他环境数据

energy/dayTask/mysql_to_hdfs.sh

@@ -39,41 +39,70 @@ mysql_to_hdfs_lzo() {
 	--null-non-string '\\N'
 }
 
+## 能源 15 分钟差值
 ods_energy_15_min(){
   mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, from_unixtime(unix_timestamp(data_time) + 28800) as data_time, data_value from energy_15_min where 1 = 1 " ods_energy_15_min
 }
 
-ods_energy_5_min(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_5_min where dt = '$do_date'" ods_energy_5_min
-}
-
+## 能源 15 分钟分精度
 ods_energy_15_min_fjd(){
   mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_15_min_fjd where dt = '$do_date'" ods_energy_15_min_fjd
 }
 
-ods_energy_5_min_fjd(){
-  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from energy_5_min_fjd where dt = '$do_date'" ods_energy_5_min_fjd
+## CO2 15 分钟分精度
+ods_co2_15_min(){
+  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from co2_15_min where dt = '$do_date'" ods_energy_15_min_fjd
+}
+
+## PM2.5 15 分钟分精度
+ods_pm25_15_min(){
+  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from pm25_15_min where dt = '$do_date'" ods_pm25_15_min
+}
+
+## 甲醛 15 分钟分精度
+ods_hcho_15_min(){
+  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from hcho_15_min where dt = '$do_date'" ods_hcho_15_min
+}
+
+## 温度 15 分钟分精度
+ods_temperature_15_min(){
+  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from temperature_15_min where dt = '$do_date'" ods_temperature_15_min
+}
+
+## 湿度 15 分钟分精度
+ods_humidity_15_min(){
+  mysql_to_hdfs_lzo $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value" "select building, func_id, meter, data_time, data_value from humidity_15_min where dt = '$do_date'" ods_humidity_15_min
 }
 
 case $1 in
-"energy_15_min")
+"all")
   ods_energy_15_min
   ods_energy_15_min_fjd
-  ;;
-"energy_5_min")
-  ods_energy_5_min
-  ods_energy_5_min_fjd
+  ods_co2_15_min
+  ods_pm25_15_min
+  ods_hcho_15_min
+  ods_temperature_15_min
+  ods_humidity_15_min
   ;;
 "ods_energy_15_min")
   ods_energy_15_min
   ;;
-"ods_energy_5_min")
-  ods_energy_5_min
-  ;;
 "ods_energy_15_min_fjd")
   ods_energy_15_min_fjd
   ;;
-"ods_energy_5_min_fjd")
-  ods_energy_5_min_fjd
+"ods_co2_15_min")
+  ods_co2_15_min
+  ;;
+"ods_pm25_15_min")
+  ods_pm25_15_min
+  ;;
+"ods_hcho_15_min")
+  ods_hcho_15_min
+  ;;
+"ods_temperature_15_min")
+  ods_temperature_15_min
+  ;;
+"ods_humidity_15_min")
+  ods_humidity_15_min
   ;;
 esac