python监控oracle数据库表数据（python 数据监控）

import time
import re
import sys
from subprocess import Popen,PIPE
import logging
logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(process)d %(threadName)s %(name)s  %(levelname)s  %(message)s')
log = logging.getLogger(__name__)

#拼接SQL
def create_sql():
    sql = "set feedback off \n"  # 不显示反馈
    sql += "set heading on \n"  #不显示列标题
    sql += "set pagesize 0 \n"
    sql += "set verify off \n"
    sql += "set echo off \n"  #不显示sql文件中的语句
    sql += "select round((((sysdate - to_date('1970-01-01 00:00:00','YYYY-MM-DD HH24:MI:SS')) * 86400000) - max(last_stat_time)) / 600000) from sys_info_test;\n"
    return sql
    
#切换oracle用户执行sqlplus命令获取翻牌延迟时间分钟数
def get_sql_list():
    sql = create_sql()
    sqlplusStr = "sqlplus -S ${username}/${password}@${jdbc}"
    sqlplusStr = sqlplusStr.replace("${username}",username).replace("${password}",password).replace("${jdbc}",jdbc)
    proc = Popen(['su','-','oracle','-c',sqlplusStr],stdout=PIPE,stdin=PIPE,stderr=PIPE)
    proc.stdin.write(sql)
    try:
        (out,err) = proc.communicate()
    except Exception as e:
        log.error('查询数据库超时')
        #结束子进程,释放
        proc.kill()
        set_exit_code(1)
        sys.exit(1)
    if proc.returncode != 0:
        sys.exit(proc.returncode)
    else:
        array = re.split(r"\n",out)
    delay_min = array[0].replace(' ','')
    return int(delay_min)
    
def get_oracle_refresh_time_delay():
    try:
        num = get_sql_list()
        print num
    except Exception as e:
        sys.exit(1)
    
if __name__=='__main__':
    get_oracle_refresh_time_delay()