欢迎访问linux宝典,请记住本站唯一域名:www.linuxbaodian.com

zabbix sender协议的研究

来源:原创    更新时间:2018-09-27 15:23:36    编辑:管理员    浏览:1145

blob.png

blob.png

blob.png

blob.png

zabbix_sender的实际例子


#!/usr/bin/env python# -*- coding: utf-8 -*-import socketimport structimport simplejsonclass ZabbixSender:
        zbx_header = 'ZBXD'
        zbx_version = 1
        zbx_sender_data = {u'request': u'sender data', u'data': []}
        send_data = ''
        def __init__(self, server_host, server_port = 10051):
                self.server_ip = socket.gethostbyname(server_host)
                self.server_port = server_port        def AddData(self, host, key, value, clock = None):
                add_data = {u'host': host, u'key': key, u'value': value}
                if clock != None:
                        add_data[u'clock'] = clock
                self.zbx_sender_data['data'].append(add_data)
                return self.zbx_sender_data        def ClearData(self):
                self.zbx_sender_data['data'] = []
                return self.zbx_sender_data        def __MakeSendData(self):
                zbx_sender_json = simplejson.dumps(self.zbx_sender_data, separators=(',', ':'), ensure_ascii=False).encode('utf-8')
                json_byte = len(zbx_sender_json)
                self.send_data = struct.pack("<4sBq" + str(json_byte) + "s", self.zbx_header, self.zbx_version, json_byte, zbx_sender_json)
        def Send(self):
                self.__MakeSendData()
                so = socket.socket()
                so.connect((self.server_ip, self.server_port))
                wobj = so.makefile(u'wb')
                wobj.write(self.send_data)
                wobj.close()
                robj = so.makefile(u'rb')
                recv_data = robj.read()
                robj.close()
                so.close()
                tmp_data = struct.unpack("<4sBq" + str(len(recv_data) - struct.calcsize("<4sBq")) + "s", recv_data)
                recv_json = simplejson.loads(tmp_data[3])
                return recv_dataif __name__ == '__main__':
        sender = ZabbixSender(u'127.0.0.1')
        for num in range(0,2):           
                sender.AddData(u'Zabbix server', u'test', u'sent data' + str(num))
        res = sender.Send()
        print sender.send_data        print res

上面的代码中

sender.AddData(u'Zabbix server', u'test', u'sent data' + str(num))

Zabbix Server为host

test为key

sent data 为value

当然,大家应该很想知道以上代码运行的结果吧,看下面

blob.png

这样就用python写了一个zabbix_sender的程序,以上的代码,只要稍作改变,即可用于我们的运维系统,如果有实际的需要。

主要步骤是和Zabbix server建立socket连接,发送zabbix的数据,注意头部信息的正确性,最后就是发送实际的数据,Zabbix server对数据进行处理响应。

官方文档为https://www.zabbix.org/wiki/Docs/protocols

下面是官方文档中java的例子

String report = buildJSonString(...);
               writeMessage(stream, report.getBytes());
...
   private String buildJSonString(String host, String item, String value)
   {
       return           "{"
       + "\"request\":\"sender data\",\n"
       + "\"data\":[\n"
       +        "{\n"
       +                "\"host\":\"" + host + "\",\n"
       +                "\"key\":\"" + item + "\",\n"
       +                "\"value\":\"" + value.replace("\\", "\\\\") + "\"}]}\n" ;
   }
   protected void writeMessage(OutputStream out, byte[] data) throws IOException {
       int length = data.length;
       out.write(new byte[] {
               'Z', 'B', 'X', 'D',
               '\1',
               (byte)(length & 0xFF),
               (byte)((length >> 8) & 0x00FF),
               (byte)((length >> 16) & 0x0000FF),
               (byte)((length >> 24) & 0x000000FF),
               '\0','\0','\0','\0'});
       out.write(data);
   }

   能自己写zabbix sender有什么好处,当然就是可以用自己的程序来发送数据给zabbix server,将极大的扩展了zabbix应用的范围和可编程性。


评论区

表情

共0条评论
  • 这篇文章还没有收到评论,赶紧来抢沙发吧~

相关内容

点击排行

随机新闻

评论排行榜