wudianlong 3 سال پیش
والد
کامیت
74e5d492f6
1فایلهای تغییر یافته به همراه6 افزوده شده و 6 حذف شده
  1. 6 6
      energy/history/mysql_to_hdfs.sh

+ 6 - 6
energy/history/mysql_to_hdfs.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-. /opt/app/bi-app/energy/history/config.sh
+. ./config.sh
 
 url=$MYSQL_URL
 username=$MYSQL_USER
@@ -13,7 +13,7 @@ import_no_partition() {
   --connect $1 \
   --username $2 \
   --password $3 \
-  --target-dir $4$7   \
+  --target-dir $4   \
   --delete-target-dir \
   --columns "$5"  \
   --query "$6  and  \$CONDITIONS" \
@@ -31,19 +31,19 @@ import_no_partition() {
 }
 
 ods_energy_15_min_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_history where 1 = 1" ods_energy_15_min_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_history where 1 = 1" ods_energy_15_min_history
 }
 
 ods_energy_5_min_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_history where 1 = 1" ods_energy_5_min_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_history where 1 = 1" ods_energy_5_min_history
 }
 
 ods_energy_15_min_fjd_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_fjd_history where 1 = 1" ods_energy_15_min_fjd_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_15_min_fjd_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_15_min_fjd_history where 1 = 1" ods_energy_15_min_fjd_history
 }
 
 ods_energy_5_min_fjd_history(){
-  import_no_partition $url $username $password /warehouse/saga_dw/ods/tmp/ "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_fjd_history where 1 = 1" ods_energy_5_min_fjd_history
+  import_no_partition $url $username $password /warehouse/saga_dw/ods/ods_energy_5_min_fjd_history "building, func_id, meter, data_time, data_value, dt" "select building, func_id, meter, data_time, data_value, dt from energy_5_min_fjd_history where 1 = 1" ods_energy_5_min_fjd_history
 }
 
 case $1 in