• 欢迎访问蜷缩的蜗牛博客 蜷缩的蜗牛
  • 微信搜索: 蜷缩的蜗牛 | 联系站长 kbsonlong@qq.com
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

zabbix 二次开发之同步CMDB主机和模板绑定

Zabbix 蜷缩的蜗牛 7个月前 (02-27) 29次浏览 已收录

    最近在做 zabbix 的二次开发;发现 zabbix 在做自动化方便提供了强悍的支持,下面分享下 CMDB 和 zabbix 打通,把 CMDB 平台里面的所有机器同步到 zabbix 数据库,然后进行批量的模板绑定:

  开发环境:

    zabbix :2.4

    python:flask 框架.前端 bootstrap,jquey:

  实现思路:

  一、

    在 CMDB 表和 ZAbbix 主机表里面建立第三张管理的表(定义叫缓存表);利用 zabbix API 把数据库里面的 host 插入到第三张缓存表;然后通过和 CMDB 库里面的比较把没有在缓存表里的数据插入到缓存表,再同步到 zabbix 数据库。

  二、

    绑定模板使用 host.update 这个 API,但是这个 API 在绑定后面的模板之后会删除已经绑定的模板,所以这里我们先遍历出前面所有的模板,然后把前面和后面的一起绑定。

缓存表的 models 结构:

 

class ZbHost(db.Model):
    __tablename__    = 'zbhost'
    id            = db.Column(db.Integer, primary_key=True)
    cmdb_hostid      = db.Column(db.Integer, index=True, unique = True)
    hostid         = db.Column(db.Integer, index=True, unique = True)
    host          = db.Column(db.String(50))
    ip           = db.Column(db.String(32))

获取数据:

def init_cmdb():
    #取 host (在 server 表里)
    hosts = api_action("server.get")
    for h in hosts:
        data = {'cmdb_hostid':h['id']}
        db.session.query(ZbHost).filter_by(ip=h['inner_ip']).update(data)
    db.session.commit()
    
    #更新到 cache 表, ip
    
def init_zabbix():
    #第一步 取出所有 host,要 ip,host,id
    zb_hosts =  zabbix_server.get_hosts()
    zb_hosts_interface = zabbix_server.get_interface([z['hostid'] for z in zb_hosts])
#    data = []
    for h in zb_hosts:
        h['ip'] = zb_hosts_interface[h['hostid']]
#       data.append(h)
    ###数据插入数据库
       db.session.add(ZbHost(**h))
    db.session.commit()

同步主机到 zabbix:

@main.route("/resource/monitor/ajax/sync_host_to_zabbix", methods=['POST'])
def sync_host_to_zabbix():
    #接收参数
    #hostid groupid
    if request.method == "POST":
        from app.common.zabbix import create_zabbix_host
        params = dict(request.form)
        hostids = params['hostids'][0].split(',')
        ret = create_zabbix_host(hostids=params['hostids'][0].split(','),groupid=params['groupid'][0])
        if len(ret) == len(hostids):
            return '1'
        else:
            return json.dumps(ret)
    return "500"

wKioL1bqe-qQ6vR2AAAqSuGlM8k873.png

zabbix 界面:

wKioL1bqfCywW0ePAAC9f6m3iSg482.png

到这里同步主机完成;下面的批量绑定模板:

 

def link_template(self, hostid, templateids):
        templates = []
        for id in templateids:
            templates.append({"templateid": id})
            print templates
            print hostid
        try:
            ret = self.zb.host.update(hostid=hostid, templates=templates)
            return ret
        except Exception as e:
            return e.message

 视图:
 
@main.route("/monitor/ajax/link_zabbix_template", methods=['POST'])
def link_zabbix_template():
    from app.common.zabbix import link_template
    if request.method == "POST":
        #1、获取前端数据
        params = dict(request.form)
        #{'hostids': [u'10106'], 'template_ids': [u'10001']}
        hostids = params['hostids'][0].split(',')
        template_ids = params['template_ids'][0].split(',')
        ret_data = link_template(hostids, template_ids)
        error = None
        for r in ret_data:
            try:
                hostids.remove(r['hostids'][0])
            except Exception, e:
                error = e.message
        if not hostids:
            return "1"
        else:
            return error
    return "500"

主机绑定模板:

wKioL1bqfumC2u1aAABFXZgf36w607.png

绑定之后:

wKiom1bqfqHxuYrpAAAlFDe3dGA172.png

登录 zabbix 查看:

wKioL1bqf6ewS8fZAADKvWPk_IM045.png

     到此 zabbix 基本的同步主机,绑定模板已经完成;zabbix 提供了非常优秀的 API,我们可以用来实现很多我们需要的功能;上面的步骤已经基本上完成了我们日常说需要的功能;当然还有解绑模板删除主机,添加维护周期等等;

本文转载自 zabbix 二次开发之同步 CMDB 主机和模板绑定


蜷缩的蜗牛 , 版权所有丨如未注明 , 均为原创丨 转载请注明zabbix 二次开发之同步 CMDB 主机和模板绑定
喜欢 (0)
[]
分享 (0)