本文共 3733 字,大约阅读时间需要 12 分钟。
接上篇,今天介绍下Returnner。
1,默认情况下,发送给minion的命令执行结果将返回给salt-master。Saltstack Returnner的接口允许将结果发送给任意系统。
GitHub:
官网:
##三、 食用过程
思路:主要用
returners
来处理saltstack执行的返回信息,通过http接口,存入数据库
###1.retrurn_http(位置/srv/salt/_returners/)
#coding=utf8import jsonimport urllibimport urllib2import osclass 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:
A:salt_report_id
,salt_report_jid
,salt_report_full_ret
干什么用?salt_report_id
指服务器客户端名称,salt_report_jid
指jid,salt_report_full_ret
指完成的返回信息。每次'。)
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)
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)转载于:https://blog.51cto.com/qdream/2409023