wdl 2 lat temu
rodzic
commit
b57430f8a5

+ 1 - 1
task_day/clean_mysql.sh

@@ -1,6 +1,6 @@
 #! /bin/bash
 
-. /mnt/datadisk0/saga/bi_saga/dwh_saga/task_day/config.sh
+. /usr/local/service/sagaApps/bi_saga/dwh_saga/task_day/config.sh
 
 if [ -n "$2" ] ;then
     do_date=$2

+ 1 - 1
task_day/hdfs_to_mysql.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-. /mnt/datadisk0/saga/bi_saga/dwh_saga/task_day/config.sh
+. /usr/local/service/sagaApps/bi_saga/dwh_saga/task_day/config.sh
 
 if [ -n "$2" ] ;then
     do_date=$2

+ 1 - 1
task_day/mysql_to_hdfs.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-. /mnt/datadisk0/saga/bi_saga/dwh_saga/task_day/config.sh
+. /usr/local/service/sagaApps/bi_saga/dwh_saga/task_day/config.sh
 
 if [ -n "$2" ] ;then
     do_date=$2

+ 1 - 1
task_day/ods_to_dwd.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-. /mnt/datadisk0/saga/bi_saga/dwh_saga/task_day/config.sh
+. /usr/local/service/sagaApps/bi_saga/dwh_saga/task_day/config.sh
 
 if [ -n "$2" ] ;then
     do_date=$2

+ 7 - 7
task_day/py_mysql.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-. /mnt/datadisk0/saga/bi_saga/dwh_saga/task_day/config.sh
+. /usr/local/service/sagaApps/bi_saga/dwh_saga/task_day/config.sh
 
 if [ -n "$2" ] ;then
     do_date=$2
@@ -37,32 +37,32 @@ echo "energy_end_time:"  "$energy_end_time"
 
 ## 能源数据
 energy_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 10101 --start_time "$energy_start_time" --end_time "$energy_end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py  10101 --start_time "$energy_start_time" --end_time "$energy_end_time"
 }
 
 ## CO2
 co2_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 11301 --start_time "$start_time" --end_time "$end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py 11301 --start_time "$start_time" --end_time "$end_time"
 }
 
 ## PM2.5
 pm25_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 11401 --start_time "$start_time" --end_time "$end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py 11401 --start_time "$start_time" --end_time "$end_time"
 }
 
 ## 甲醛
 hcho_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 11305 --start_time "$start_time" --end_time "$end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py  11305 --start_time "$start_time" --end_time "$end_time"
 }
 
 ## 温度
 temperature_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 11101 --start_time "$start_time" --end_time "$end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py  11101 --start_time "$start_time" --end_time "$end_time"
 }
 
 ## 湿度
 humidity_hbase_to_mysql(){
-  /usr/local/bin/python3 /mnt/datadisk0/saga/bi_saga/python_transfer/start_mysql.py 11201 --start_time "$start_time" --end_time "$end_time"
+  /usr/bin/sshpass -p dwh@2021 ssh root@82.157.25.216 /mnt/datadisk0/saga/service/python3/bin/python3 /mnt/datadisk0/saga/bi_saga/transfer_data/start_mysql.py  11201 --start_time "$start_time" --end_time "$end_time"
 }