【玩转Lighthouse】利用Python调用云Api实现多地域快速导出轻量应用服务器详细信息

python3 -V

pip install -i https://mirrors.tencent.com/pypi/simple/ --upgrade tencentcloud-sdk-python

pip install -i https://mirrors.tencent.com/pypi/simple/ pandas

import json
import pandas as pd
from time import time, strftime, localtime
from tencentcloud.common import credential
from tencentcloud.common.profile.client_profile import ClientProfile
from tencentcloud.common.profile.http_profile import HttpProfile
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.lighthouse.v20200324 import lighthouse_client, models

start = time()
aria = ['ap-beijing', 'ap-chengdu', 'ap-guangzhou', 'ap-hongkong', 'ap-shanghai', 'ap-singapore',
        'na-siliconvalley','eu-moscow', 'ap-tokyo', 'ap-nanjing', 'ap-mumbai', 'eu-frankfurt']
aria_zh = ['北京', '成都', '广州', '中国香港', '上海', '新加坡', '硅谷', '莫斯科', '东京', '南京', '孟买', '法兰克福']

# 此处添加SecretId 与 SecretKey
cred = credential.Credential("SecretId", "SecretKey")

httpProfile = HttpProfile()
httpProfile.endpoint = "lighthouse.tencentcloudapi.com"
clientProfile = ClientProfile()
clientProfile.httpProfile = httpProfile

lh_id = []
lh_name = []
lh_state = []
lh_aria = []
lh_zone = []
lh_cpu = []
lh_memory = []
lh_os = []
lh_bandwidth = []
lh_public_ip = []
lh_private_ip = []
lh_disk_size = []
lh_created_time = []
lh_expired_time = []
lh_tft = []
lh_tfu = []
lh_tfr = []

print('代码运行中 预计30s导出完毕')

for i in range(12):
    client = lighthouse_client.LighthouseClient(cred, aria[i], clientProfile)
    # 获取实例信息
    try:
        # 查看所有实例
        req = models.DescribeInstancesRequest()
        params = {}
        req.from_json_string(json.dumps(params))
        resp = client.DescribeInstances(req)
        response = json.loads(resp.to_json_string())
        # print(response)
        # 实例详细信息

        # 判断地域是否含有实例
        if response['TotalCount'] > 0:
            # print(aria_zh[i] + '实例数为' + str(response['TotalCount']))
            # 提取返回的json信息
            for ii in range(response['TotalCount']):
                lh_id.append(response['InstanceSet'][ii]['InstanceId'])
                lh_name.append(response['InstanceSet'][ii]['InstanceName'])
                lh_state.append(response['InstanceSet'][ii]['InstanceState'])
                lh_aria.append(aria_zh[i])
                zone = response['InstanceSet'][ii]['Zone']
                zone_rep = zone.replace('{0}-'.format(aria[i]), '')
                lh_zone.append(zone_rep)
                lh_cpu.append(response['InstanceSet'][ii]['CPU'])
                lh_memory.append(response['InstanceSet'][ii]['Memory'])
                lh_os.append(response['InstanceSet'][ii]['OsName'])
                lh_bandwidth.append(response['InstanceSet'][ii]['InternetAccessible']['InternetMaxBandwidthOut'])
                lh_public_ip.append(response['InstanceSet'][ii]['PublicAddresses'][0])
                lh_private_ip.append(response['InstanceSet'][ii]['PrivateAddresses'][0])
                lh_disk_size.append(response['InstanceSet'][ii]['SystemDisk']['DiskSize'])
                lh_created_time.append(response['InstanceSet'][ii]['CreatedTime'])
                lh_expired_time.append(response['InstanceSet'][ii]['ExpiredTime'])
                # 查看流量包
                try:
                    req1 = models.DescribeInstancesTrafficPackagesRequest()

                    params1 = {"InstanceIds": [response['InstanceSet'][ii]['InstanceId']]}

                    req1.from_json_string(json.dumps(params1))

                    resp1 = client.DescribeInstancesTrafficPackages(req1)

                    response1 = json.loads(resp1.to_json_string())
                    tf = response1['InstanceTrafficPackageSet'][0]['TrafficPackageSet'][0]
                    # 总流量
                    tft = str(round(tf['TrafficPackageTotal'] / 1073741824, 2))
                    lh_tft.append(tft)
                    # 已用流量
                    tfu = str(round(tf['TrafficUsed'] / 1073741824, 2))
                    lh_tfu.append(tfu)
                    # 剩余流量
                    tfr = str(round(tf['TrafficPackageRemaining'] / 1073741824, 2))
                    lh_tfr.append(tfr)

                except TencentCloudSDKException as err:
                    print(err)

    except TencentCloudSDKException as err:
        print(err)

dataframe = pd.DataFrame({'ID': lh_id, '实例名': lh_name, '状态':lh_state, '地域': lh_aria, '可用区': lh_zone,
                          'CPU(核数)': lh_cpu, '内存(GB)': lh_memory, '操作系统': lh_os, '带宽(Mbps)': lh_bandwidth,
                          'IPv4公网IP': lh_public_ip, 'IPv4内网IP': lh_private_ip, '系统盘大小(GB)': lh_disk_size,
                          '创建时间': lh_created_time, '到期时间': lh_expired_time, '流量包大小(GB)': lh_tft, '流量包已用流量(GB)': lh_tfu,
                          '流量包剩余流量(GB)': lh_tfr})
csv_name = 'lh_{0}.csv'.format(strftime('%Y-%m-%d %H_%M_%S', localtime()))
dataframe.to_csv(csv_name, encoding='utf_8_sig')

print('导出完毕 文件名为{0}'.format(csv_name))
end = time()
print('本次代码执行共耗时：', round(end - start, 2), 's')