update

dbConfig/getData.py

@@ -3,13 +3,13 @@
 import random
 import requests
 import time
-import os,sys
+import os, sys
 import socket, struct
-from dbConfig.dbConn import MysqlCon
-
+import datetime
 curPath = os.path.abspath(os.path.dirname(__file__))
 rootPath = os.path.split(curPath)[0]
 sys.path.append(rootPath)
+from dbConfig.dbConn import MysqlCon
 
 # host = "10.3.20.32"
 host = "etl.cma5jkozme68.rds.cn-north-1.amazonaws.com.cn"
@@ -18,7 +18,9 @@ username = "rytestalarm"
 # password = "reyun.123"
 password = "rytestalarm234"
 db = "tkio_stream"
-sql = "select num_click from tkio_rpt_source_analysis_day where appid ='b563860ef7f3400a5fe7c0a05f4523e6';"
+dt = datetime.datetime.now().strftime('%Y-%m-%d')
+sql = "select num_click from tkio_rpt_source_analysis_day where appid ='b563860ef7f3400a5fe7c0a05f4523e6' and " \
+      "dt=curdate(); "
 
 # URL = 'http://10.3.20.42:8083/tkio/Bzq2aua'
 URL = 'http://uri6.com/tkio/ziQ7Jza'
@@ -41,12 +43,8 @@ time.sleep(360)
 mysqlCon = MysqlCon(host=host, username=username, password=password, db=db)
 r = mysqlCon.get_one(sql=sql)
 num = r[0]
-
+print(count, num)
 if count + 1 == num:
     print("指标确认正常")
 else:
     print("指标异常，请关注")
-
-
-
-

dbConfig/main.py

 # -*- coding: utf-8 -*-
 
 import dbConfig.dbConn
+import os,sys
+
+curPath = os.path.abspath(os.path.dirname(__file__))
+rootPath = os.path.split(curPath)[0]
+sys.path.append(rootPath)
+
+sql = "select num_click from tkio_rpt_source_analysis_day where appid ='b563860ef7f3400a5fe7c0a05f4523e6' and " \
+      "dt=curdate(); "
+print(sys.path)
+print(rootPath)
\ No newline at end of file