基于django+ansible+webssh运维自动化管理系统

标签：name 运维 models webssh dic back django user password

基于django+ansible+webssh运维自动化管理系统

前言

最初开发这个基于Django ansible运维自动化管理系统的想法其实从大学时候就已经有了，但是苦于技术原因和没有线上环境原因一直没有开发，现在有了这个技术和环境之后开始着手开发了这个项目，项目难点在于你要理解如何设计数据库，如果调用ansible_api，怎么调用web_ssh插件来管理主机，感谢那些总结好ansible_api和webssh大佬，有了这个丝路之后开发一个成熟的项目就是增删改查和具体插件也就不是很难了

1、项目说明

基于django+ansible+webssh运维自动化管理系统

项目需要安装pycharm专业版以及MySQL环境（环境搭建可以看我的B站里的视频有讲解）

首先需要创建数据库数据库名字叫做order_test（这里你可以自己换数据库名称）
运行sql导入数据或者也可以直接用命令生成（视频有讲解）

DATABASES = {

'default': {

'ENGINE': 'django.db.backends.mysql',

'NAME': 'order_test',

'USER': 'root',

'PASSWORD': 'password',

'HOST': 'host',

'PORT': 3306,

}

CREATE DATABASE `order_test` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci */;

需要安装一下下面的模块（如果运行提示有模块未安装，安装一下即可，命令同下，改一下模块名即可）

项目需要安装 Django、及其附带的其他一些模块
安装命令如下：

pip3 install -r requirements.txt

2、项目主要技术

python编程技术

mysql数据库技术

django框架技术

Ansible使用

Webssh

前端技术

3、 项目主要功能

分为管理员，用户两个角色，管理可以增删改查用户
管理可以增删改查主机
管理员可以为用户分配不同的组
用户可以操作对应组的主机
实现远程web_ssh连接服务器
实现用户可以执行playbook剧本
实现用户可以执行 ad_hoc 命令
实现审计功能，可以查看玩家历史操作
集成bootstrap前端模板

4、项目结构

Ansible_renwu 主程序（项目的配置文件、主路由）

Ansible_web 主要视图逻辑增删改查

templates 前端页面

manage.py 程序的入口

5、部分源码

models.py

class UserInfo(AbstractUser):
    # user_name = models.CharField(u'用户名',max_length=30)
    # user_pass = models.CharField(u'密码',max_length=80,blank=True,null=True,default="")
    user_email = models.EmailField(verbose_name='邮箱',max_length=60)
    phone = models.BigIntegerField(verbose_name='手机号', null=True, blank=True)
    create_time = models.DateField(auto_now_add=True)

    user_group = models.ManyToManyField("group",related_name='yonghuzu')

    def __unicode__(self):
        return self.user_email

    def __unicode__(self):
        return self.group_name

class zhuji(models.Model):
    zhujiname = models.CharField(verbose_name='主机名',max_length=255)
    ipaddr = models.CharField(verbose_name='ip地址',max_length=255)
    zhuji_group = models.ForeignKey("group",verbose_name='主机组',max_length=255,on_delete=models.CASCADE)
    zhuji_source = models.CharField(verbose_name='主机来源',max_length=255)

# 定义ansible执行任务的任务的主机-playbook_url-playbook_name
class ansible_renwu(models.Model):

    playbook_name=models.CharField(verbose_name='playbook_name',max_length=255,default='')
    zhuji=models.CharField(verbose_name='主机',max_length=255)
    mokuai=models.CharField(verbose_name='mokuai',max_length=255,default='')

6、后端部分代码：

# 用户注册接口
def register(request):
    form_obj = MyRegForm()
    if request.method == 'POST':
        back_dic = {"code": 1000, 'msg': ''}
        # 校验数据是否合法
        form_obj = MyRegForm(request.POST)

        # 判断数据是否合法
        if form_obj.is_valid():
            # print(form_obj.cleaned_data) # {'username': 'jason', 'password': '123', 'confirm_password': '123', 'email': '[email protected]'}
            clean_data = form_obj.cleaned_data # 将校验通过的数据字典赋值给一个变量
            # 将字典里面的confirm_password键值对删除
            clean_data.pop('confirm_password') # {'username': 'jason', 'password': '123', 'email': '[email protected]'}

            # 直接操作数据库保存数据这里 create_user 创建的密码是密文状态
            models.UserInfo.objects.create_user(**clean_data)
            back_dic['url'] = '/login/'
        else:
            back_dic['code'] = 2000
            back_dic['msg'] = form_obj.errors
        return JsonResponse(back_dic)
    return render(request, 'register.html', locals())

# 用户登陆接口
def login(request):
    if request.method == 'POST':
        back_dic = {'code': 1000, 'msg': ''}
        username = request.POST.get('username')
        password = request.POST.get('password')
        user_obj = auth.authenticate(request,username=username,password=password)
        # print(user_obj)
        print(username,password)
        # user = models.UserInfo.objects.filter(user_name=username, user_pass=password).first()

        if user_obj:
            print('123')
            auth.login(request, user_obj)
            back_dic['url'] = '/ansible/'
            back_dic['msg'] = '登录成功'
            print(back_dic)
        else:
            back_dic['code'] = 2000
            back_dic['msg'] = '用户名或密码错误'

        # 这里对应 POST 必须返回一个 return 方法
        return JsonResponse(back_dic)

    return render(request, 'login.html',locals())