100 lines
3 KiB
Plaintext
Executable file
100 lines
3 KiB
Plaintext
Executable file
#!/usr/bin/env python3
|
|
# vim: set filetype=python:
|
|
|
|
import sys
|
|
import time
|
|
import urllib.parse
|
|
|
|
import requests
|
|
|
|
from drive_utils import (build_fqdn, get_ips_for_hostname, run_remote_command,
|
|
smoketest_db_node)
|
|
|
|
|
|
def add_downtime(fqdn: str,
|
|
apikey: str,
|
|
monitor_host: str = 'monitor.drive.test.sunet.se') -> None:
|
|
if not apikey:
|
|
return
|
|
print("\tAdding downtime for: {}".format(fqdn))
|
|
action = 'schedule_host_svc_downtime'
|
|
|
|
start_time = int(time.time())
|
|
end_time = start_time + (10 * 60) # 10 minutes
|
|
data = {
|
|
'comment_data': 'Reboot from script',
|
|
'start_time': start_time,
|
|
'end_time': end_time
|
|
}
|
|
|
|
post_url = 'https://{}/thruk/r/hosts/{}/cmd/{}'.format(
|
|
monitor_host, fqdn, action)
|
|
headers = {'X-Thruk-Auth-Key': apikey}
|
|
requests.post(post_url, data=data, headers=headers)
|
|
|
|
|
|
def remove_downtime(fqdn: str,
|
|
apikey: str,
|
|
monitor_host: str = 'monitor.drive.test.sunet.se') -> None:
|
|
if not apikey:
|
|
return
|
|
print("\tRemoving downtime for: {}".format(fqdn))
|
|
get_url = 'https://{}/thruk/r/hosts?name={}&columns=services'.format(
|
|
monitor_host, fqdn)
|
|
headers = {'X-Thruk-Auth-Key': apikey}
|
|
req = requests.get(get_url, headers=headers)
|
|
action = 'del_active_service_downtimes'
|
|
for service in req.json()[0]['services']:
|
|
post_url = 'https://{}/thruk/r/services/{}/{}/cmd/{}'.format(
|
|
monitor_host, fqdn, urllib.parse.quote(service), action)
|
|
requests.post(post_url, headers=headers)
|
|
|
|
|
|
def main() -> int:
|
|
customer = "<%= @customer %>"
|
|
environment = "<%= @environment %>"
|
|
apikey_test = "<%= @apikey_test %>"
|
|
apikey_prod = "<%= @apikey_prod %>"
|
|
user = "script"
|
|
|
|
reboot_command = ['sudo /usr/local/bin/safer_reboot']
|
|
|
|
for number in reversed(range(1, 4)):
|
|
fqdn = build_fqdn(customer, environment, number)
|
|
ipv4, _ = get_ips_for_hostname(fqdn)
|
|
ip = ipv4[0]
|
|
print("Upgrading: {} with ip: {}".format(fqdn, ip))
|
|
add_downtime(fqdn, apikey_test)
|
|
add_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")
|
|
|
|
run_remote_command(fqdn, reboot_command, user = user)
|
|
success = False
|
|
|
|
for testnumber in reversed(range(1, 32, 2)):
|
|
print("\tSleeping for {} seconds before smoketest on {}".format(
|
|
testnumber, fqdn))
|
|
time.sleep(testnumber)
|
|
|
|
if smoketest_db_node(fqdn, user = user):
|
|
success = True
|
|
|
|
break
|
|
|
|
remove_downtime(fqdn, apikey_test)
|
|
remove_downtime(fqdn, apikey_prod, monitor_host="monitor.drive.sunet.se")
|
|
if success:
|
|
print("Upgrade cycle succeeded on {} ".format(fqdn))
|
|
else:
|
|
print("Smoketest failed on {} after server reboot command".format(
|
|
fqdn))
|
|
|
|
return 5
|
|
print("All {}-servers successfully upgraded for {}".format(
|
|
environment, customer))
|
|
|
|
return 0
|
|
|
|
|
|
if __name__ == "__main__":
|
|
sys.exit(main())
|