py_mysql.sh 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. #!/bin/bash
  2. #. /opt/app/bi-app/energy/dayTask/config.sh
  3. if [ -n "$2" ] ;then
  4. echo "如果是输入的日期按照取输入日期"
  5. do_date=$2
  6. startSec=`date -d "$do_date" "+%s"`
  7. echo $startSec
  8. current_day=`date -d "@$startSec" "+%Y-%m-%d"`
  9. one_day_ago=`date -d "$current_day yesterday" +%Y%m%d`
  10. start_time=`date -d "-2 day $current_day" +%Y%m%d`160000
  11. end_time=`date -d "-1 day $current_day" +%Y%m%d`160000
  12. else
  13. echo "====没有输入数据的日期,取当前时间的前一天===="
  14. start_time=`date -d "-2 day" +"%Y%m%d"`160000
  15. end_time=`date -d "-1 day" +"%Y%m%d"`160000
  16. fi
  17. echo $start_time
  18. echo $end_time
  19. #
  20. # 11301 CO2
  21. # 11401 PM2.5
  22. # 11305 甲醛
  23. # 11101 温度
  24. # 11201 湿度
  25. ## 能源数据
  26. energy_hbase_to_mysql(){
  27. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 10101 --start_time $start_time --end_time $end_time
  28. }
  29. ## CO2
  30. co2_hbase_to_mysql(){
  31. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11301 --start_time $start_time --end_time $end_time
  32. }
  33. ## PM2.5
  34. pm25_hbase_to_mysql(){
  35. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11401 --start_time $start_time --end_time $end_time
  36. }
  37. ## 甲醛
  38. hcho_hbase_to_mysql(){
  39. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11305 --start_time $start_time --end_time $end_time
  40. }
  41. ## 温度
  42. temperature_hbase_to_mysql(){
  43. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11101 --start_time $start_time --end_time $end_time
  44. }
  45. ## 湿度
  46. humidity_hbase_to_mysql(){
  47. /usr/local/bin/python3 /opt/app/python_transfer/start_mysql.py 11201 --start_time $start_time --end_time $end_time
  48. }
  49. case $1 in
  50. "all")
  51. energy_hbase_to_mysql
  52. co2_hbase_to_mysql
  53. pm25_hbase_to_mysql
  54. hcho_hbase_to_mysql
  55. temperature_hbase_to_mysql
  56. humidity_hbase_to_mysql
  57. ;;
  58. "energy")
  59. energy_hbase_to_mysql
  60. ;;
  61. "co2")
  62. co2_hbase_to_mysql
  63. ;;
  64. "pm25")
  65. pm25_hbase_to_mysql
  66. ;;
  67. "hcho")
  68. hcho_hbase_to_mysql
  69. ;;
  70. "temperature")
  71. temperature_hbase_to_mysql
  72. ;;
  73. "humidity")
  74. humidity_hbase_to_mysql
  75. ;;
  76. esac