|
@@ -128,7 +128,7 @@ mysql = {
|
|
}
|
|
}
|
|
my_database = os.getenv("database")
|
|
my_database = os.getenv("database")
|
|
dingding = os.getenv("dingding")
|
|
dingding = os.getenv("dingding")
|
|
-
|
|
|
|
|
|
+at_mobiles = os.getenv("at_mobiles")
|
|
|
|
|
|
while True:
|
|
while True:
|
|
time_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
time_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
@@ -161,12 +161,12 @@ while True:
|
|
if feedback_sum == len(duplicate_data_sum):
|
|
if feedback_sum == len(duplicate_data_sum):
|
|
print("%s 时间段%s至%s,处理数据%s条,成功!"%(datetime_now(),create_time_start,create_time_end,feedback_sum))
|
|
print("%s 时间段%s至%s,处理数据%s条,成功!"%(datetime_now(),create_time_start,create_time_end,feedback_sum))
|
|
# message = ("【feedback表打唯一数据标签】 %s 时间段%s至%s,处理数据%s条,成功 \n") % (datetime_now(),create_time_start,create_time_end,feedback_sum)
|
|
# message = ("【feedback表打唯一数据标签】 %s 时间段%s至%s,处理数据%s条,成功 \n") % (datetime_now(),create_time_start,create_time_end,feedback_sum)
|
|
- # send_message_mobiles(message,dingding,15727360513)
|
|
|
|
|
|
+ # send_message_mobiles(message,dingding,at_mobiles)
|
|
|
|
|
|
else:
|
|
else:
|
|
print("%s 时间段%s至%s,查询数据%s条,插入数据%s条,失败!"%(datetime_now(),create_time_start,create_time_end,feedback_sum,len(duplicate_data_sum)))
|
|
print("%s 时间段%s至%s,查询数据%s条,插入数据%s条,失败!"%(datetime_now(),create_time_start,create_time_end,feedback_sum,len(duplicate_data_sum)))
|
|
message = ("【feedback表打唯一数据标签】 %s 时间段%s至%s,查询数据%s条,插入数据%s条,失败 \n")%(datetime_now(),create_time_start,create_time_end,feedback_sum,len(duplicate_data_sum))
|
|
message = ("【feedback表打唯一数据标签】 %s 时间段%s至%s,查询数据%s条,插入数据%s条,失败 \n")%(datetime_now(),create_time_start,create_time_end,feedback_sum,len(duplicate_data_sum))
|
|
- send_message_mobiles(message,dingding,15727360513)
|
|
|
|
|
|
+ send_message_mobiles(message,dingding,at_mobiles)
|
|
MysqlUtil.close()
|
|
MysqlUtil.close()
|
|
|
|
|
|
|
|
|