getData.py 1.45 KB
# -*- coding: utf-8 -*-

import random
import requests
import time
import os
import sys
import socket
import struct

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"
# username = "root"
username = "rytestalarm"
# password = "reyun.123"
password = "rytestalarm234"
db = "tkio_stream"
sql = "select num_click from tkio_rpt_source_analysis_day where appid ='b563860ef7f3400a5fe7c0a05f4523e6' and " \
      "dt=DATE_FORMAT((date_add(now(), interval 8 hour)),'%Y-%m-%d');"

# URL = 'http://10.3.20.42:8083/tkio/Bzq2aua'
URL = 'http://uri6.com/tkio/ziQ7Jza'
i = ''.join(str(random.choice(range(10))) for _ in range(12))
ip = socket.inet_ntoa(struct.pack('>I', random.randint(1, 0xffffffff)))
param = {
    "imei": i,
    "ip": ip,
    "deviceid": i
}

mysqlCon = MysqlCon(host=host, username=username, password=password, db=db)
r = mysqlCon.get_one(sql=sql)
if r is None:
    count = 0
else:
    count = r[0]
# 解决运行警告问题
requests.packages.urllib3.disable_warnings()
p = requests.get(url=URL, params=param, timeout=30, verify=False)

time.sleep(400)

mysqlCon = MysqlCon(host=host, username=username, password=password, db=db)
r = mysqlCon.get_one(sql=sql)
num = r[0]
print(count, num)

if num > count:
    print("指标确认正常")
else:
    # print("指标异常,请关注")
    1 / 0