# -*- coding: utf-8 -*
import sys,json,urllib2,pymysql
reload(sys)
sys.setdefaultencoding('utf8')
# 1.连接到mysql数据库
conn = pymysql.connect(host='目标主机', user='用户名', password='密码', db='数据库名', charset='utf8')
# localhost连接本地数据库 user 用户名 password 密码 db数据库名称 charset 数据库编码格式
# 2.创建游标对象
cursor = pymysql.cursors.SSCursor(conn)
# 3.组装sql语句 需要查询的MySQL语句
sql = "查询语句 n 进行换行"
# 4.执行sql语句
cursor.execute(sql)
# 定义token，绑定的是固定的一个群机器人，如果要更换发送的目的群就更换这个token
token = '自定义机器人的Webhook'
# 定义url、headers不用动
url = 'https://oapi.dingtalk.com/robot/send?access_token='+token
headers = {"Content-Type": "application/json"}
while True:
row = cursor.fetchone()
if not row:
break
# 封装报警信息，可以自定义，+号后边是数据库查出来的内容 'n'
msg = '报警消息'
# 定义请求参数，不用动 at 人员
data = {'msgtype' : 'text','text' : {"content": msg},'at':{"isAtAll": False ,"atMobiles": 手机号}}
data = json.dumps(data)
request = urllib2.Request(url,data = data,headers = headers)
# 定义一个变量接收请求的执行结果，=号后边是发送请求的代码，如果不需要接收请求结果可以不要response
response = urllib2.urlopen(request)
print(row)
# print(msg.encode('utf-8'))
cursor.close()
