"""
python 清理 consul 无效的服务
"""

import requests
import json
import os
def clear_consul_services():
    base_url = "10.98.0.1:30086"
    # base_url = "192.168.13.250:8500"
    api_url = "http://" + base_url + "/v1/health/state/critical"
    deregister_url = "http://" + base_url + "/v1/agent/service/deregister/"
    print("consul服务地址:",deregister_url)
    rep = requests.get(url=api_url)
    if rep.status_code != 200:
        print("consul connect: no host")
        return False
    rep_json_data = json.loads(rep.text)
    service_id_list = []
    for i in rep_json_data:
        service_id = i.get("ServiceID")
        service_id_list.append(service_id)
    print(service_id_list)
    for i in service_id_list:
        url = deregister_url + i
        print("consul无效服务:",url)
        rep = requests.put(url=url)
        print(rep.status_code)

clear_consul_services()