• 【日常运维】CMDB轻松管理千百台服务器---jumpserver堡垒机

     本站以分享各种运维经验和运维所需要的技能为主

    《python零基础入门》：python零基础入门学习

    《python运维脚本》： python运维脚本实践

    《shell》：shell学习

    《terraform》持续更新中：terraform_Aws学习零基础入门到最佳实战

    《k8》暂未更新

    《docker学习》暂未更新

    《ceph学习》ceph日常问题解决分享

    《日志收集》ELK+各种中间件

    《运维日常》运维日常

    《linux》运维面试100问

     【日常运维】CMDB轻松管理千百台服务器---jumpserver堡垒机

    背景：

    公司的服务器日益增多的时候，管理起来就需要一个cmdb的平台进行管理。

    介绍：

    JumpServer 是广受欢迎的开源堡垒机，是符合 4A 规范的专业运维安全审计系统。

    JumpServer 使用 Python 开发，配备了业界领先的 Web Terminal 方案，交互界面美观、用户体验好。

    JumpServer 采纳分布式架构，支持多机房跨区域部署，支持横向扩展，无资产数量及并发限制。

    改变世界，从一点点开始。

    安装部署：

    安装部署 - JumpServer 文档

    [工作随笔]JumpServer排坑安装及二次开发-腾讯云开发者社区-腾讯云

    Python调用Jumpserver的Api接口增删改查：

    满足添加自动添加云机器信息入jumpserver。

    1. # -*- coding: utf-8 -*-
    2.  
    3.  
    4. import requests, datetime, json
    5. from httpsig.requests_auth import HTTPSignatureAuth
    6.  
    7. KeyID = '77e76d19-141c-4545--xxx'
    8. SecretID = 'a04817bc-0bb1-439f-baa2-xxxx'
    9. gmt_form = '%a, %d %b %Y %H:%M:%S GMT'
    10. ptivate_token = 'xxxxx'
    11.  
    12. headers = {
    13.     'accept': 'application/json',
    14.     'Content-Type': 'application/json',
    15.     # 'X-CSRFToken': 'eoLo2AVcQK5X1JQ392JHCzjZ8wPCWZJFJao5O9ObH8zQwtiPhGBzaOnNKjaENShf',
    16.     "Authorization": 'Token ' + ptivate_token,
    17.     'X-JMS-ORG': '00000000-0000-0000-0000-000000000002',
    18.     'Date': datetime.datetime.utcnow().strftime(gmt_form)
    19. }
    20.  
    21.  
    22. # 认证
    23. def get_auth(KeyID, SecretID):
    24.     """
    25.     认证
    26.     :param KeyID:  The key ID
    27.     :param SecretID:    The secret ID
    28.     :return:
    29.     """
    30.     signature_headers = ['(request-target)', 'accept', 'date']
    31.     auth = HTTPSignatureAuth(key_id=KeyID, secret=SecretID, algorithm='hmac-sha256', headers=signature_headers)
    32.     return auth
    33.  
    34.  
    35. auth = get_auth(KeyID, SecretID)
    36.  
    37.  
    38. # 获取所有用户
    39. def get_user_all():
    40.     """
    41.     获取所有用户
    42.     :return:
    43.     """
    44.     url = jms_url + '/api/v1/users/users/'
    45.     response = requests.get(url, auth=auth, headers=headers)
    46.     user_list = json.loads(response.text)
    47.     count = 0
    48.     for i in user_list:
    49.         count += 1
    50.         print(i)
    51.     print(count)
    52.  
    53.  
    54. # 获取监控指标
    55. def get_prometheus_metric():
    56.     """
    57.     获取监控指标
    58.     :return:
    59.     """
    60.     url = jms_url + "/api/v1/prometheus/metrics/"
    61.     response = requests.get(url, headers=headers, auth=auth)
    62.     print(response.text)
    63.     return response.text
    64.  
    65.  
    66. # 获取所有资产节点
    67. def get_node_all():
    68.     """
    69.     获取所有资产节点
    70.     :return:
    71.     """
    72.     url = jms_url + "/api/v1/assets/nodes/"
    73.     response = requests.get(url, headers=headers, auth=auth)
    74.     node_list = json.loads(response.text)
    75.     count = 0
    76.     for i in node_list:
    77.         count += 1
    78.         print(i)
    79.     print(count)
    80.     return response.json()
    81.  
    82.  
    83. # 查看当前token（即admin）的所有资产
    84. def get_asset_all():
    85.     """
    86.     查看当前token（即admin）的所有资产
    87.     :return:
    88.     """
    89.     url = jms_url + "/api/v1/assets/assets/"
    90.     response = requests.get(url, headers=headers, auth=auth)
    91.     node_list = json.loads(response.text)
    92.     count = 0
    93.     for i in node_list:
    94.         count += 1
    95.         print(i)
    96.     print(count)
    97.     return response.json()
    98.  
    99.  
    100. ###################################################################################################
    101. # 创建资产节点
    102. def assets_nodes_create(node_name):
    103.     """
    104.     创建资产节点
    105.     :param node_name:
    106.     :return:
    107.     """
    108.     node_data = {
    109.         "value": node_name
    110.     }
    111.     url = jms_url + "/api/v1/assets/nodes/"
    112.     node_info = get_node_info(node_name)
    113.     if node_info:  # 根据node_name去查询，如果查到了说明已经有了。
    114.         print("{name}已存在, id: {id}".format(name=node_name, id=node_info[0]["id"]))
    115.     else:
    116.         data = json.dumps(node_data)
    117.         resp = requests.post(url, headers=headers, data=data)
    118.         return resp.json()
    119.  
    120.  
    121. #
    122. def get_assets_list_by_ip(ip):
    123.     """
    124.     根据ip获取资产信息
    125.     :param ip:
    126.     :return:
    127.     """
    128.     url = jms_url + "/api/v1/assets/assets/"
    129.     response = requests.get(url, headers=headers, params={
    130.         "ip": ip
    131.     })
    132.     print(response.json())
    133.     return response.json()
    134.  
    135.  
    136. # 查看资产节点信息
    137. def get_node_info(node_name):
    138.     """
    139.     查看资产节点信息
    140.     :param node_name:   节点名称
    141.     :return:
    142.     """
    143.     url = jms_url + "/api/v1/assets/nodes/"
    144.     response = requests.get(url, auth=auth, headers=headers, params={
    145.         "value": node_name
    146.     })
    147.     print(response.text)
    148.     return response.json()
    149.  
    150.  
    151. # 创建资产机器
    152. def asset_create(ip, hostname, node_id, comment):
    153.     """
    154.     创建资产机器
    155.     :param ip:  ip地址
    156.     :param hostname:   主机名
    157.     :param node_id:   节点id
    158.     :return:    返回创建的资产信息
    159.     """
    160.     asset_Data = {
    161.         "name": hostname,
    162.         "address": ip,
    163.         "platform": "1",
    164.         "protocols": [{
    165.  
    166.             "name": "ssh",
    167.             "port": 22
    168.         }],
    169.         "is_active": True,
    170.         "nodes": [node_id],
    171.         "comment": comment,
    172.         "accounts": [{
    173.             # 账号模板id
    174.             "template": "60b11033-a6e1-467d-8388-68a0e64134ff",
    175.         }]
    176.     }
    177.     url = jms_url + "/api/v1/assets/hosts/"
    178.     print(url)
    179.     data = json.dumps(asset_Data)
    180.     print(data)
    181.     response = requests.post(url, auth=auth, headers=headers, data=data)
    182.     print(response.text)
    183.  
    184.  
    185. # 运行创建服务器资产
    186. def run_create_assets(node_name, project_name, ip, comment):
    187.     """
    188.     运行创建服务器资产
    189.     :param node_name:  节点名称
    190.     :param project_name:  机器名称
    191.     :param ip:  ip地址
    192.     :param comment:  备注
    193.     :return:
    194.     """
    195.     # 节点id，无节点时创建节点
    196.     node_info = get_node_info(node_name)
    197.  
    198.     # 如果len(node_info) == 0 说明没有节点，需要创建节点
    199.     if len(node_info) == 0:
    200.         # 创建节点
    201.         node_id = assets_nodes_create(node_name)
    202.         print(node_id)
    203.     else:
    204.         # 获取节点id
    205.         node_id = node_info[0]["id"]
    206.         print(node_id)
    207.     # 管理用户 id
    208.     hostname = "{ip}_{project_name}".format(ip=ip, project_name=project_name)
    209.     # 查IP,创建资产
    210.     ip_info = get_assets_list_by_ip(ip)
    211.     if ip_info:
    212.         print("%s 已存在，nodes: %s" % (ip_info[0]["address"], ip_info[0]["nodes"]))
    213.     else:
    214.         asset_create(ip, hostname, node_id, comment)
    215.  
    216.  
    217. def get_org_info():
    218.     """
    219.     获取组织信息
    220.     :return:
    221.     """
    222.     url = jms_url + "/api/v1/orgs/orgs/"
    223.     response = requests.get(url, headers=headers)
    224.     org_list = response.text
    225.     print(org_list)
    226.     for i in org_list.split("id"):
    227.         print(i)
    228.  
    229.     return response.json()
    230.  
    231.  
    232. if __name__ == '__main__':
    233.     jms_url = 'https://jms.xxx.top'
    234.     username = 'admin'
    235.     password = 'xxxxxx'
    236.  
    237.     # 获取token
    238.     # token = get_token(jms_url, username, password)
    239.  
    240.     # 创建资产节点
    241.     # assets_nodes_create("k8s")
    242.  
    243.     # 根据ip获取资产信息
    244.     # get_assets_list_by_ip("192.168.11.10")
    245.  
    246.     # 查看资产节点信息
    247.     # get_node_info("k8s")
    248.  
    249.     # 创建资产调用
    250.     # node_id = ["e8641c37-93e3-450e-aaf8-64d5baa69753"]
    251.     # get_node_info("k8s")
    252.     # asset_create(ip, hostname, node_id)
    253.  
    254.     # 运行创建服务器资产
    255.     # run_create_assets("test", "风控", "192.168.11.10", "测试")
    256.  
    257.     # 获取组织信息
    258.     # get_org_info()
    259.  
    260.     # 获取所有用户
    261.     get_user_all()
    262.

    二次开发：jumpserver同步腾讯云主机信息

    需要基础是django 的大框架以及一些前端知识

    jumpserver同步腾讯云主机信息 - 简书

  • 相关阅读:
    华测视频RTK，AR实景导航
    车载音频系统中的数据通信
    CH455G驱动数码管
    【操作系统】Lesson1-什么是操作系统
    一次Python无法安装模块的问题探索与解决之旅
    Android 10 SystemUI 如何添加4G信号和WiFi图标
    js内存与数据
    List获取差集产生的问题
    选择需求管理工具
    IDEA运行项目报错：Command line is too long的解决办法
  • 原文地址：https://blog.csdn.net/zerotoall/article/details/140458850