25 lines
736 B
Python
25 lines
736 B
Python
# -*- coding: UTF-8 -*-
|
|
|
|
import pymysql
|
|
|
|
class set_point_expire(object):
|
|
def set_point_expire(self,ipx,unacloud_ip):
|
|
db=pymysql.connect(unacloud_ip,"root","1223Bc@2008","unacloud",port=3306,charset='utf8')
|
|
cursor=db.cursor()
|
|
try:
|
|
sql_search_id = "SELECT * FROM resource_server WHERE public_ip = '" + ipx + "'"
|
|
cursor.execute(sql_search_id)
|
|
search_id_results = cursor.fetchall()
|
|
for row in search_id_results:
|
|
point_ip = row[0]
|
|
print("强制过期的灾备节点id为 %s" %point_ip)
|
|
sql_set_expire = "update charge_server_duration set expired_time = DATE_SUB(NOW(),INTERVAL 31 day) where server_id='" + point_ip + "'"
|
|
cursor.execute(sql_set_expire)
|
|
db.commit()
|
|
except:
|
|
print("麻蛋出错了")
|
|
db.close()
|
|
|
|
|
|
|