授之以渔-运维平台Saltstack Web 管理一（Returnner篇）

63 阅读 0 评论 42 点赞

我是靠谱客的博主冷酷水杯，这篇文章主要介绍授之以渔-运维平台Saltstack Web 管理一（Returnner篇），现在分享给大家，希望可以做个参考。

接上篇《授之以渔-运维平台Saltstack Web 管理一（模块管理篇）》，今天介绍下Returnner。

一，returnner介绍

1，默认情况下，发送给minion的命令执行结果将返回给salt-master。Saltstack Returnner的接口允许将结果发送给任意系统。

GitHub：https://github.com/saltstack/salt/tree/develop/salt/returners

官网：https://docs.saltstack.com/en/latest/ref/returners/

二，returnner模块列表

##三、食用过程

思路：主要用returners来处理saltstack执行的返回信息，通过http接口，存入数据库

###1.retrurn_http（位置/srv/salt/_returners/）

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
#coding=utf8
import json
import urllib
import urllib2
import os

class Salt_post:
    def __init__(self):
        self.opener=urllib2.build_opener(urllib2.HTTPCookieProcessor())
        urllib2.×××tall_opener(self.opener)
    def salt_post(self,salt_report_id,salt_report_jid,salt_report_full_ret):
        self.salt_report_id=salt_report_id
        self.salt_report_jid=salt_report_jid
        self.salt_report_full_ret=salt_report_full_ret
        _str=urllib.urlencode({'salt_report_id':self.salt_report_id,'salt_report_jid':self.salt_report_jid,'salt_report_full_ret':self.salt_report_full_ret})
        _response=urllib2.urlopen('http://veronica.youth.cn/cmdb/salt_returners/',_str)

def __virtual__():
    return 'return_redis'

def returner(ret):
    x=Salt_post()
    x.salt_post(ret['id'],ret['jid'],json.dumps(ret))

Q:为什么选择http的方式?
A:因为returners需要在每个客户端上执行，如果使用常规的mysql或者redis方式，直接写入数据库，需要在每个机器上装python的mysql或者redis扩展，无疑增加劳动力。

Q:salt_report_id,salt_report_jid,salt_report_full_ret干什么用?
A:salt_report_id指服务器客户端名称，salt_report_jid指jid，salt_report_full_ret指完成的返回信息。每次'http://veronica.youth.cn/cmdb/salt_salt_returners/被触发后，我会分别对我的Salt_hosts及Salt_report表进行更新。（更新这里效仿了puppet的Foreman中有hosts和reports两张表，有兴趣的同学可自行查看分别维护这每次主机信息和变更信息。)

models如下：

复制代码

class Salt_hosts(models.Model):
    class Meta:
        verbose_name = 'Salt_host'
        verbose_name_plural = verbose_name
        ordering = ['salt_hosts_name'] 
    salt_hosts_name = models.CharField("主机名称",max_length=45)          
    salt_hosts_last_jid = models.CharField("jid",max_length=25,blank=True)
    salt_hosts_last_jid_time = models.CharField('最后jid时间',max_length=35,blank=True)
    salt_hosts_last_success_status = models.CharField("执行状态",max_length=10,blank=True)
    salt_hosts_last_models_success_count = models.CharField("模块执行成功",max_length=10,blank=True)
    salt_hosts_last_models_fail_count = models.CharField("模块执行失败",max_length=10,blank=True)
    salt_hosts_models_group = models.ForeignKey(Salt_models_group,verbose_name="执行模块组")
    salt_hosts_model = models.CharField("执行模块",max_length=10,blank=True)
    salt_change_at = models.DateTimeField('最后更改时间',auto_now=True)

class Salt_report(models.Model):
    class Meta:
        verbose_name = 'Salt_report'
        verbose_name_plural = verbose_name 
    salt_report_fun = models.CharField("功能",max_length=25)
    salt_report_fun_args = models.CharField("参数",max_length=100,blank=True,null=True)
    salt_report_jid = models.CharField("jid",max_length=25)
    salt_report_id = models.CharField("id",max_length=45)
    salt_report_success = models.CharField("状态",max_length=10)
    salt_report_full_ret = models.TextField('结果',blank=True,max_length=2000) 
    salt_report_time = models.CharField('执行时间',max_length=35)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
class Salt_hosts(models.Model):
    class Meta:
        verbose_name = 'Salt_host'
        verbose_name_plural = verbose_name
        ordering = ['salt_hosts_name'] 
    salt_hosts_name = models.CharField("主机名称",max_length=45)          
    salt_hosts_last_jid = models.CharField("jid",max_length=25,blank=True)
    salt_hosts_last_jid_time = models.CharField('最后jid时间',max_length=35,blank=True)
    salt_hosts_last_success_status = models.CharField("执行状态",max_length=10,blank=True)
    salt_hosts_last_models_success_count = models.CharField("模块执行成功",max_length=10,blank=True)
    salt_hosts_last_models_fail_count = models.CharField("模块执行失败",max_length=10,blank=True)
    salt_hosts_models_group = models.ForeignKey(Salt_models_group,verbose_name="执行模块组")
    salt_hosts_model = models.CharField("执行模块",max_length=10,blank=True)
    salt_change_at = models.DateTimeField('最后更改时间',auto_now=True)  

class Salt_report(models.Model):
    class Meta:
        verbose_name = 'Salt_report'
        verbose_name_plural = verbose_name 
    salt_report_fun = models.CharField("功能",max_length=25)
    salt_report_fun_args = models.CharField("参数",max_length=100,blank=True,null=True)
    salt_report_jid = models.CharField("jid",max_length=25)
    salt_report_id = models.CharField("id",max_length=45)
    salt_report_success = models.CharField("状态",max_length=10)
    salt_report_full_ret = models.TextField('结果',blank=True,max_length=2000) 
    salt_report_time = models.CharField('执行时间',max_length=35)

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
Salt_report(salt_report_fun=salt_report_fun,
                            salt_report_id=salt_report_id,
                            salt_report_jid=salt_report_jid,
                            salt_report_full_ret=salt_report_full_ret,
                            salt_report_success=salt_report_success,
                            salt_report_fun_args=salt_report_fun_args,
                            salt_report_time=salt_report_time).save()

Salt_hosts(salt_hosts_name=salt_report_id,
                           salt_hosts_last_jid=salt_report_jid,
                           salt_hosts_last_jid_time=salt_report_time,
                           salt_hosts_last_success_status=salt_report_success,
                           salt_hosts_last_models_success_count=success_count,
                           salt_hosts_last_models_fail_count=fail_count).save()

###2.Salt_hosts（类似Forman的reports）

###2.Salt_repot（类似Forman的hosts）