|
@@ -2,9 +2,9 @@
|
|
|
|
|
|
#. /opt/app/bi-app/energy/dayTask/config.sh
|
|
#. /opt/app/bi-app/energy/dayTask/config.sh
|
|
|
|
|
|
-if [ -n "$1" ] ;then
|
|
|
|
|
|
+if [ -n "$2" ] ;then
|
|
echo "如果是输入的日期按照取输入日期"
|
|
echo "如果是输入的日期按照取输入日期"
|
|
- do_date=$1
|
|
|
|
|
|
+ do_date=$2
|
|
startSec=`date -d "$do_date" "+%s"`
|
|
startSec=`date -d "$do_date" "+%s"`
|
|
echo $startSec
|
|
echo $startSec
|
|
current_day=`date -d "@$startSec" "+%Y-%m-%d"`
|
|
current_day=`date -d "@$startSec" "+%Y-%m-%d"`
|
|
@@ -20,4 +20,69 @@ fi
|
|
echo $start_time
|
|
echo $start_time
|
|
echo $end_time
|
|
echo $end_time
|
|
|
|
|
|
-/usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 10101 --start_time $start_time --end_time $end_time
|
|
|
|
|
|
+#
|
|
|
|
+# 11301 CO2
|
|
|
|
+# 11401 PM2.5
|
|
|
|
+# 11305 甲醛
|
|
|
|
+# 11101 温度
|
|
|
|
+# 11201 湿度
|
|
|
|
+
|
|
|
|
+## 能源数据
|
|
|
|
+energy_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 10101 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+## CO2
|
|
|
|
+co2_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11301 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+## PM2.5
|
|
|
|
+pm25_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11401 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+## 甲醛
|
|
|
|
+hcho_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11305 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+## 温度
|
|
|
|
+temperature_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11101 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+## 湿度
|
|
|
|
+humidity_hbase_to_mysql(){
|
|
|
|
+ /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11201 --start_time $start_time --end_time $end_time
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+case $1 in
|
|
|
|
+"all")
|
|
|
|
+ energy_hbase_to_mysql
|
|
|
|
+ co2_hbase_to_mysql
|
|
|
|
+ pm25_hbase_to_mysql
|
|
|
|
+ hcho_hbase_to_mysql
|
|
|
|
+ temperature_hbase_to_mysql
|
|
|
|
+ humidity_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"energy")
|
|
|
|
+ energy_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"co2")
|
|
|
|
+ co2_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"pm25")
|
|
|
|
+ pm25_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"hcho")
|
|
|
|
+ hcho_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"temperature")
|
|
|
|
+ temperature_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+"humidity")
|
|
|
|
+ humidity_hbase_to_mysql
|
|
|
|
+ ;;
|
|
|
|
+esac
|