概述
为了方便单位资产的管理，运维部门一般会开发一套自己的CMDB管理系统，如果没有自己开发，那基于jumpserver的二次开发是一个不错的选择。本文就介绍一下如何通过python调用腾讯云SDK实现同步腾讯云主机到jumpserver资产列表。
环境及开发前准备
python版本：python2.7
os 版本：ubuntu 14.04
-
安装Python SDK
pip install tencentcloud-sdk-python 获取
SecretID和SecretKey
使用腾讯云SDK之前需要先获取其安全凭证，安全凭证即SecretID和SecretKey；SecretID用于标识API调用者的身份，SecretKey用于加密签名字符串和服务器端验证签名字符串的密钥，二者需要到腾讯云控制台云申请：控制台 - 云产品 - 管理工具 - 云API密钥 - API密钥管理，点击“新建密钥”即可生成SecretID和SecretKey。
同步qcloud资产
-
增加url
url(r'^asset/qcloud_asset_sync/$', qcloud_asset_sync, name='qcloud_asset_sync') -
资产列表增加 ‘同步qcloud资产’ 按钮
<a href="{% url 'qcloud_asset_sync' %}" class="btn btn-sm btn-primary "> 同步qcloud资产 </a> 修改view.py
- 通过SDK获取到腾讯云的主机数据
- 将主机数据直接存储到数据库
获取腾讯云主机信息
首先要确定自己的主机在哪个地域(即Regin)，比如：上海，北京，多伦多，硅谷，其相对应的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
# 导入对应产品模块的client models。
from tencentcloud.cvm.v20170312 import cvm_client, models
SecretId = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
secretKey = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
Region = 'ap-beijing'
try:
# 实例化一个认证对象，入参需要传入腾讯云账户secretId，secretKey
cred = credential.Credential(SecretId, secretKey)
# 实例化要请求产品(以cvm为例)的client对象
client = cvm_client.CvmClient(cred, Region)
# 实例化一个请求对象
req = models.DescribeInstancesRequest()
# 通过client对象调用想要访问的接口，需要传入请求对象
resp = client.DescribeInstances(req)
# 输出json格式的字符串回包
print resp.to_json_string()
except TencentCloudSDKException as err:
print err
输出参数
| 参数名称 | 说明 |
|---|---|
| TotalCount | 实例个数 |
| InstanceSet | 实例详细列表 |
| RequestId | 唯一请求ID，每次请求都会返回 |
我们主要关注的就是前两个，可是当你实例超过20个的时候，此时你会发现返回结果中，只有20个实例，别的实例去哪里了呢？这是腾讯云限制单次请求默认只返回20条数据，最大值为100，这个是输出参数中的一个Limit参数控制的，所以如果我们云服数量大的话，可以按需设置这个参数
这里假如我有200多台服务器，要同步到jumpserver，所以要先获取云端总的服务器数量，计算请求次数，设置limit为100，offset偏移量为0
def get_qcloud_servers():
SecretId = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
secretKey = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
Region = 'ap-beijing'
try:
# 实例化一个认证对象，入参需要传入腾讯云账户secretId，secretKey
cred = credential.Credential(SecretId, secretKey)
# 实例化要请求产品(以cvm为例)的client对象
client = cvm_client.CvmClient(cred, Region)
# 实例化一个请求对象
req = models.DescribeInstancesRequest()
# 通过client对象调用想要访问的接口，需要传入请求对象
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
将主机信息添加到数据库
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'))
效果
最终功能实现就是通过点击同步qcloud资产按钮实现把腾讯云上的资产同步到jumpsercer上
