Django項目：CMDB(服務器硬件資產自動采集系統)--01--01CMDB獲取服務器基本信息

 

 

 

AutoClient

 

 

 

#settings.py
# ————————01CMDB獲取服務器基本信息————————
import os

BASEDIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))##當前路徑

# 采集資產的方式，選項有：agent(默認), salt, ssh
MODE = 'agent'

# ————————01CMDB獲取服務器基本信息————————

 

 

#base.py
# ————————01CMDB獲取服務器基本信息————————
from config import settings  #配置文件

class BasePlugin(object):
    def __init__(self, hostname=''):
        if hasattr(settings, 'MODE'):
            self.mode = settings.MODE #采集資產的方式
        else:
            self.mode = 'agent'#默認,采集資產的方式

    def execute(self):
        return self.windows()

    def windows(self):
        raise Exception('您必須實現windows的方法')
# ————————01CMDB獲取服務器基本信息————————

 

#response.py
# ————————01CMDB獲取服務器基本信息————————
class BaseResponse(object): #提交數據的類型
    def __init__(self):
        self.status = True      #狀態
        self.message = None     #消息
        self.data = None        #數據內容
        self.error = None       #錯誤信息

# ————————01CMDB獲取服務器基本信息————————

 

 

 

#auto-client.py
# ————————01CMDB獲取服務器基本信息————————
import os
BASEDIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#當前路徑
print('當前路徑:',type(BASEDIR),BASEDIR)
os.path.join(BASEDIR)# Join(轉成字符串)

from src.scripts import client
if __name__ == '__main__':#讓你寫的腳本模塊既可以導入到別的模塊中用，另外該模塊自己也可執行
    client()
# ————————01CMDB獲取服務器基本信息————————

 

 

 

# scripts.py
# ————————01CMDB獲取服務器基本信息————————
from src.client import AutoAgent  #本地采集模式
from config import settings       #配置文件

def client(): #根據配置文件判斷采集模式
    if settings.MODE == 'agent':
        cli = AutoAgent()  #本地采集模式
    else:
        raise Exception('請配置資產采集模式，如：agent、ssh、salt')
    cli.process() #執行def process(self):
# ————————01CMDB獲取服務器基本信息————————

 

 

 

# client.py
# ————————01CMDB獲取服務器基本信息————————
from src import plugins  #__init__.py
from lib.serialize import Json #轉成字符串或者模式

class AutoBase(object):
    def process(self):#派生類需要繼承此方法，用於處理請求的入口
        raise NotImplementedError('您必須實現過程的方法')
class AutoAgent(AutoBase):
    def process(self):
        server_info = plugins.get_server_info()#獲取本地基本信息
        server_json = Json.dumps(server_info.data)#json.dumps將 Python 對象編碼成 JSON 字符串
        print('提交資產信息:',server_json)

# ————————01CMDB獲取服務器基本信息————————

 

 

 

#__init__.py
# ————————01CMDB獲取服務器基本信息————————
from src.plugins.basic import BasicPlugin

def get_server_info(hostname=None):
    """
    獲取服務器基本信息
    :param hostname: agent模式時，hostname為空；salt或ssh模式時，hostname表示要連接的遠程服務器
    :return:
    """
    response = BasicPlugin(hostname).execute()#獲取基本信息
    """
    class BaseResponse(object):
        def __init__(self):
            self.status = True
            self.message = None
            self.data = None
            self.error = None   
    """
    return response

if __name__ == '__main__':
    ret = get_server_info()
# ————————01CMDB獲取服務器基本信息————————

 

 

# basic.py
# ————————01CMDB獲取服務器基本信息————————
from .base import BasePlugin #采集資產的方式
from lib.response import BaseResponse   #提交數據的類型
import platform  #platform模塊給我們提供了很多方法去獲取操作系統的信息
import wmi#Windows操作系統上管理數據和操作的基礎設施
"""
本模塊基於windows操作系統，依賴wmi和win32com庫，需要提前使用pip進行安裝，
我們依然可以通過pip install pypiwin32來安裝win32com模塊
或者下載安裝包手動安裝。
"""

class BasicPlugin(BasePlugin):
    def os_platform(self):#獲取系統平台
        output=platform.system()
        return output.strip()#strip() 方法用於移除字符串頭尾指定的字符（默認為空格或換行符）或字符序列。
    def os_version(self):#獲取系統版本
        output = wmi.WMI().Win32_OperatingSystem()[0].Caption
        return output.strip()#strip() 方法用於移除字符串頭尾指定的字符（默認為空格或換行符）或字符序列。
    def os_hostname(self):#獲取主機名
        output = wmi.WMI().Win32_OperatingSystem()[0].CSName
        return output.strip()#strip() 方法用於移除字符串頭尾指定的字符（默認為空格或換行符）或字符序列。

    def windows(self):
        response = BaseResponse()#提交數據的類型
        try:
            ret = {
                'os_platform': self.os_platform(),#系統平台
                'os_version': self.os_version(),#系統版本
                'hostname': self.os_hostname(),#主機名
            }
            response.data = ret #字典形式
            print('windows服務器基本信息:',response.data)
        except Exception as e:
            response.status = False#獲取信息時出現錯誤
        return response
    """
    class BaseResponse(object): #提交數據的類型
    def __init__(self):
        self.status = True      #狀態
        self.message = None     #消息
        self.data = None        #數據內容
        self.error = None       #錯誤信息

    """
# ————————01CMDB獲取服務器基本信息————————

 

 

import wmi
"""
本模塊基於windows操作系統，依賴wmi和win32com庫，需要提前使用pip進行安裝，
我們依然可以通過pip install pypiwin32來安裝win32com模塊
或者下載安裝包手動安裝。
"""

 

 

#serialize.py
# ————————01CMDB獲取服務器基本信息————————
import json as default_json  #輕量級的數據交換格式
from json.encoder import JSONEncoder  #JSONEncoder用來將模型轉JSON字符串，JSONDecoder是用來將JSON字符串轉為模型
from .response import BaseResponse

class JsonEncoder(JSONEncoder):
    def default(self, o):
        if isinstance(o, BaseResponse):#isinstance()函數來判斷一個對象是否是一個已知的類型
            return o.__dict__  #返回字典
        return JSONEncoder.default(self, o) #JSONEncoder用來將模型轉JSON字符串，JSONDecoder是用來將JSON字符串轉為模型
    """
    不是這個類型就不處理，直接返回
    class BaseResponse(object):
        def __init__(self):
            self.status = True  #狀態
            self.message = None  #消息
            self.data = None  #數據內容
            self.error = None  #錯誤信息

    """
class Json(object):
    @staticmethod#返回函數的靜態方法
    def dumps(response, ensure_ascii=True):
        return default_json.dumps(response, ensure_ascii=ensure_ascii, cls=JsonEncoder)#dumps 方法是將 json 的 dict 形式，轉換成為字符串 str 類型

# ————————01CMDB獲取服務器基本信息————————