概述

為了方便單位資產(chǎn)的管理，運(yùn)維部門一般會(huì)開發(fā)一套自己的CMDB管理系統(tǒng)，如果沒有自己開發(fā)，那基于jumpserver的二次開發(fā)是一個(gè)不錯(cuò)的選擇。本文就介紹一下如何通過python調(diào)用騰訊云SDK實(shí)現(xiàn)同步騰訊云主機(jī)到j(luò)umpserver資產(chǎn)列表。

環(huán)境及開發(fā)前準(zhǔn)備

• python版本：python2.7

• os 版本：ubuntu 14.04

• 安裝Python SDK

  pip install tencentcloud-sdk-python
  

• 獲取SecretID和SecretKey
  使用騰訊云SDK之前需要先獲取其安全憑證，安全憑證即SecretID和SecretKey；SecretID用于標(biāo)識API調(diào)用者的身份，SecretKey用于加密簽名字符串和服務(wù)器端驗(yàn)證簽名字符串的密鑰，二者需要到騰訊云控制臺(tái)云申請：控制臺(tái) - 云產(chǎn)品 - 管理工具 - 云API密鑰 - API密鑰管理，點(diǎn)擊“新建密鑰”即可生成SecretID和SecretKey。

同步qcloud資產(chǎn)

• 增加url

  url(r'^asset/qcloud_asset_sync/$', qcloud_asset_sync, name='qcloud_asset_sync')
  

• 資產(chǎn)列表增加 ‘同步qcloud資產(chǎn)’ 按鈕

  <a href="{% url 'qcloud_asset_sync' %}" class="btn btn-sm btn-primary "> 同步qcloud資產(chǎn) </a>
  

• 修改view.py

1. 通過SDK獲取到騰訊云的主機(jī)數(shù)據(jù)
2. 將主機(jī)數(shù)據(jù)直接存儲(chǔ)到數(shù)據(jù)庫

獲取騰訊云主機(jī)信息

首先要確定自己的主機(jī)在哪個(gè)地域(即Regin)，比如：上海，北京，多倫多，硅谷，其相對應(yīng)的Region為：ap-shanghai，ap-beijing，na-toronto，na-siliconvalley，其它各Region可以通過查詢地域列表查詢

示例

# -*- coding: utf-8 -*-
from tencentcloud.common import credential
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
# 導(dǎo)入對應(yīng)產(chǎn)品模塊的client models。
from tencentcloud.cvm.v20170312 import cvm_client, models

SecretId = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
secretKey = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
Region = 'ap-beijing'
try:
    # 實(shí)例化一個(gè)認(rèn)證對象，入?yún)⑿枰獋魅腧v訊云賬戶secretId，secretKey
    cred = credential.Credential(SecretId, secretKey)

    # 實(shí)例化要請求產(chǎn)品(以cvm為例)的client對象
    client = cvm_client.CvmClient(cred, Region)

    # 實(shí)例化一個(gè)請求對象
    req = models.DescribeInstancesRequest()

    # 通過client對象調(diào)用想要訪問的接口，需要傳入請求對象
    resp = client.DescribeInstances(req)
    # 輸出json格式的字符串回包
    print resp.to_json_string()

except TencentCloudSDKException as err:
    print err

輸出參數(shù)

我們主要關(guān)注的就是前兩個(gè)，可是當(dāng)你實(shí)例超過20個(gè)的時(shí)候，此時(shí)你會(huì)發(fā)現(xiàn)返回結(jié)果中，只有20個(gè)實(shí)例，別的實(shí)例去哪里了呢？這是騰訊云限制單次請求默認(rèn)只返回20條數(shù)據(jù)，最大值為100，這個(gè)是輸出參數(shù)中的一個(gè)Limit參數(shù)控制的，所以如果我們云服數(shù)量大的話，可以按需設(shè)置這個(gè)參數(shù)

這里假如我有200多臺(tái)服務(wù)器，要同步到j(luò)umpserver，所以要先獲取云端總的服務(wù)器數(shù)量，計(jì)算請求次數(shù)，設(shè)置limit為100，offset偏移量為0

def get_qcloud_servers():
    SecretId = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
    secretKey = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
    Region = 'ap-beijing'

    try:
        # 實(shí)例化一個(gè)認(rèn)證對象，入?yún)⑿枰獋魅腧v訊云賬戶secretId，secretKey
        cred = credential.Credential(SecretId, secretKey)
        # 實(shí)例化要請求產(chǎn)品(以cvm為例)的client對象
        client = cvm_client.CvmClient(cred, Region)
        # 實(shí)例化一個(gè)請求對象
        req = models.DescribeInstancesRequest()
        # 通過client對象調(diào)用想要訪問的接口，需要傳入請求對象
        resp = client.DescribeInstances(req)
        # 輸出json格式的字符串回包
        totalServer = json.loads(resp.to_json_string())['TotalCount']
    except TencentCloudSDKException as err:
        print err

    offset, loop = (0, 0)
    servers = []
    while loop < totalServer / 100 + 1:
        module = 'cvm'
        action = 'DescribeInstances'
        config = {
            'Region': Region,
            'secretId': SecretId,
            'secretKey': secretKey
        }

        action_params = {
            'limit': 100,
            'offset': offset
        }

        loop += 1
        offset += 100

        try:
            service = QcloudApi(module, config)
            cvms = json.loads(service.call(action, action_params))['instanceSet']
            servers_loop = [cvm for cvm in cvms]
            servers.extend(servers_loop)
        except Exception as e:
            import traceback
            print 'traceback.format_exc():\n%s' % traceback.format_exc()

    return servers

將主機(jī)信息添加到數(shù)據(jù)庫

def qcloud_asset_sync(request):
    servers = get_qcloud_servers()
    qcloud_server_ips = []
    for server in servers:
        qcloud_server_ips.append(server['lanIp'])
        s = Asset.objects.filter(ip=server['lanIp'])
        if s:
            s.update(hostname=server['instanceName'],system_type=server['os'],cpu=server['cpu'],memory=server['mem'],disk=server['diskInfo'].get('storageSize',0),port=22)
        else:
            Asset(hostname=server['instanceName'],ip=server['lanIp'],system_type=server['os'],cpu=server['cpu'],memory=server['mem'],disk=server['diskInfo'].get('storageSize',0),port=22).save()

    return HttpResponseRedirect(reverse('asset_list'))

效果
最終功能實(shí)現(xiàn)就是通過點(diǎn)擊同步qcloud資產(chǎn)按鈕實(shí)現(xiàn)把騰訊云上的資產(chǎn)同步到j(luò)umpsercer上

page.jpg