Django通过json格式收集主机信息

下面就为大家详细讲解一下Django如何通过json格式收集主机信息的完整攻略：

1. 确定主机信息收集的方式

首先需要确定主机信息收集的方式。可以借助第三方工具比如ansible、saltstack等进行信息收集，也可以编写脚本通过ssh协议获取。这里以编写脚本通过ssh获取主机信息的方式进行说明。

2. 定义json格式

为了收集主机信息后方便进行存储和查询，需要定义好收集到的信息的json格式。下面是一个示例：

{
    "hostname": "myhostname.example.com",
    "ip": "192.168.1.100",
    "cpu": "Intel(R) Xeon(R) CPU E3-1230 v6 @ 3.50GHz",
    "memory": "8GB",
    "disk_space": {
        "/": {
            "total": "100GB",
            "used": "50GB",
            "free": "50GB"
        },
        "/var": {
            "total": "200GB",
            "used": "20GB",
            "free": "180GB"
        }
    },
    "service_status": {
        "nginx": "active",
        "mysql": "inactive"
    }
}

3. 编写信息收集脚本

接下来需要编写脚本实现通过ssh连接到远程主机获取主机信息的操作。例如，可以使用Python的paramiko模块来实现远程ssh连接，然后通过执行cat /proc/meminfo这样的命令获取内存信息，并将得到的结果转换为json数据。

示例代码：

import paramiko
import re
import json

def get_memory_info(ip, username, password):
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(ip, username=username, password=password)
    stdin, stdout, stderr = ssh.exec_command("cat /proc/meminfo")
    meminfo = stdout.read().decode('utf-8')
    ssh.close()

    # 解析获取的内存信息
    pattern = re.compile(r'(\w+):\s+(\d+)\s+kB')
    match_list = pattern.findall(meminfo)
    mem_dict = {}
    for item in match_list:
        mem_dict[item[0]] = int(item[1]) / 1024 /1024

    # 转换成json格式并返回
    json_str = json.dumps({"memory": mem_dict})
    return json_str

4. 定义Django视图函数和模型

在Django中，需要定义视图函数和模型来接收并存储从主机收集的信息。首先在models.py文件中定义存储主机信息的模型：

from django.db import models

class Host(models.Model):
    hostname = models.CharField(max_length=50, verbose_name="主机名")
    ip = models.CharField(max_length=20, verbose_name="IP地址")
    cpu = models.CharField(max_length=50, verbose_name="CPU型号")
    memory = models.CharField(max_length=20, verbose_name="内存大小")
    disk_space = models.TextField(verbose_name="磁盘使用情况")
    service_status = models.TextField(verbose_name="服务状态")
    created_at = models.DateTimeField(auto_now_add=True, verbose_name="创建时间")

    class Meta:
        verbose_name = "主机信息"
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.hostname

然后定义视图函数，接收POST请求并将收集到的主机信息存储到数据库中：

from django.views.decorators.csrf import csrf_exempt
from django.http import JsonResponse
from .models import Host

@csrf_exempt
def collect_host_info(request):
    if request.method == 'POST':
        # 从请求中获取json数据
        json_str = request.body.decode('utf-8')
        data_dict = json.loads(json_str)

        # 将信息存储到数据库
        host = Host(
            hostname=data_dict['hostname'],
            ip=data_dict['ip'],
            cpu=data_dict['cpu'],
            memory=data_dict['memory'],
            disk_space=json.dumps(data_dict['disk_space']),
            service_status=json.dumps(data_dict['service_status']),
        )
        host.save()

        return JsonResponse({'status': 'success'})
    else:
        return JsonResponse({'status': 'error', 'msg': 'wrong request method'})

5. 收集主机信息并上报到Django

最后，在主机上执行脚本，将收集到的主机信息通过POST请求的方式上报到Django服务器。可以使用curl命令来模拟POST请求：

$ curl -d '{"hostname": "myhostname.example.com","ip": "192.168.1.100","cpu": "Intel(R) Xeon(R) CPU E3-1230 v6 @ 3.50GHz","memory": "8GB","disk_space": {"/": {"total": "100GB","used": "50GB","free": "50GB"},"/var": {"total": "200GB","used": "20GB","free": "180GB"}},"service_status": {"nginx": "active","mysql": "inactive"}}' -H 'Content-Type: application/json' http://yourdjangoip:port/collect_host_info/

这样就可以将收集到的主机信息存储到Django的数据库中了，可以根据需要自行查询和展示。