Chinaunix首页 | 论坛 | 博客

Kingsh2012 ChinaUnixBlog

首页　| 　博文目录　| 　关于我

kingsh2012

  • 博客访问： 244378
  • 博文数量： 32
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 414
  • 用 户 组： 普通用户
  • 注册时间： 2014-04-22 11:22
个人简介

.....

文章分类

全部博文（32）

文章存档

2016年（1）

2015年（12）

2014年（19）

我的朋友
最近访客
推荐博文
相关博文
zabbix通过API创建交换机模板,ifAdminStatus;ifOperStatus;ifInUcastPkts;ifAlias

分类： 系统运维

2015-08-04 17:37:36

最终效果：




目的：
        通过zabbix的Latest data查看主机就可以看到其监控结果。

监控项：
        # 管理状态 
        IF-MIB::ifAdminStatus.
        # 操作状态 
        IF-MIB::ifOperStatus.
        # 接收 单播包 
        IF-MIB::ifInUcastPkts.
        # 发送 单播包
        IF-MIB::ifOutUcastPkts.
        # 接收 错误包 
        IF-MIB::ifInErrors.
        # 发送 错误包
        IF-MIB::ifOutErrors.
        # 接收 列队 
        IF-MIB::ifInQLen.
        # 发送 列队
        IF-MIB::ifOutQLen.
        # 接收 多播包 
        IF-MIB::ifInMulticastPkts.
        # 发送 多播包
        IF-MIB::ifOutMulticastPkts.
        # 接收 广播包 
        IF-MIB::ifInBroadcastPkts.
        # 发送 广播包
        IF-MIB::ifOutBroadcastPkts.
       # 接收 非单播包
       IF-MIB::ifInNUcastPkts.
       # 发送 非单播包
       IF-MIB::ifOutNUcastPkts
        # 端口描述 
        IF-MIB::ifAlias.

基础环境：
       centos6.5
       xampp集成环境
       snmpwalk

流程原理：
       通过shell截取snmpwalk出来的index对应端口信息存入MYSQL表内，PHP脚本读取存入MYSQL表内的信息，通过给予的OID名字进行字符串截取生成item名字,KEY,OID创建items，一单items被创建成功，会返回itmeids，脚本讲把这个ID与其他信息存入另一个MYSQL表内。

目录结构：
       snmpwalk.sh               # SNMP信息截取  调用
       insert_snmp_oid.php    # SNMP信息写入  使用
       zbx.inc.php                  #  ZABBIX API     调用
       zbx.templates.class.php   # 创建模板    调用
       usage.php                      # 创建模板    使用

MYSQL表内容

点击(此处)折叠或打开

  1. --
  2. -- 表的结构 `snmp_oid`
  3. --

  5. CREATE TABLE IF NOT EXISTS `snmp_oid` (
  6.   `ID` int(11) NOT NULL AUTO_INCREMENT,
  7.   `IP` varchar(255) NOT NULL,
  8.   `COMMUNITY` varchar(255) NOT NULL,
  9.   `VERSION` varchar(10) DEFAULT NULL,
  10.   `OID_index` varchar(255) NOT NULL,
  11.   `OID_port` varchar(255) NOT NULL,
  12.   `OID_in` varchar(255) NOT NULL,
  13.   `OID_out` varchar(255) NOT NULL,
  14.   PRIMARY KEY (`ID`)
  15. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0 ;

点击(此处)折叠或打开

  1. --
  2. -- 表的结构 `items_plus`
  3. --

  5. CREATE TABLE IF NOT EXISTS `items_plus` (
  6.   `id` int(11) NOT NULL AUTO_INCREMENT,
  7.   `hostid` int(50) NOT NULL,
  8.   `snmp_index` varchar(50) DEFAULT NULL,
  9.   `itemids` int(50) NOT NULL,
  10.   `items_name` varchar(50) DEFAULT NULL,
  11.   `items_key` varchar(50) DEFAULT NULL,
  12.   `items_oid` varchar(50) DEFAULT NULL,
  13.   `ApplicationID` int(10) NOT NULL,
  14.   PRIMARY KEY (`id`)
  15. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0 ;

脚本内容：
 snmpwalk.sh    

点击(此处)折叠或打开

  1. #!/bin/bash

  3. # 迈普交换机设置成 mp
  4. # 锐捷或者华为 随便设定一个值就行。
  5. a="cc"

  7. # 函数

  9. # 生成索引文件
  10. function index() {
  11.     if [ $a == "mp" ];then
  12.         #snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'gi' |awk -F'[ ,=]' '{print $1}' > index.txt
  13.         snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'port' |awk -F'[ ,=]' '{print $1}' > index.txt
  14.     else
  15.         snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'Ethernet' |awk -F'[ ,=]' '{print $1}' > index.txt
  16.     fi
  17. }

  19. # 生成端口名称
  20. function port() {
  21.     if [ $a == "mp" ];then
  22.         #snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'gi' |awk -F'[ ,=]' '{print $5 $6}' > port.txt
  23.         snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'port' |awk -F'[ ,=]' '{print $5 $6}' > port.txt
  24.     else
  25.         snmpwalk -$version -c $community $ip IF-MIB::ifDescr |grep 'Ethernet' |awk -F'[ ,=]' '{print $5 $6}' > port.txt
  26.     fi
  27. }

  29. # 删除生成txt文件
  30. function del(){
  31.     rm -rf ./in.txt out.txt index.txt port.txt
  32. }

  34. # 生成端口流入文件
  35. function _in(){
  36.     if [ -f "index.txt" ];then
  37.         cp ./index.txt in.txt
  38.         
  39.         #SNMP v1
  40.         if [ $version == "v1" ];then
  41.             sed -i "s/IF-MIB::ifDescr/IF-MIB::ifInOctets/g" `grep IF-MIB::ifDescr -rl in.txt `
  42.         fi

  44.         #SNMP v2c
  45.         if [ $version == "v2c" ];then
  46.             sed -i "s/IF-MIB::ifDescr/IF-MIB::ifHCInOctets/g" `grep IF-MIB::ifDescr -rl in.txt `
  47.         fi
  48.  
  49.     else
  50.         echo "not index.txt"
  51.     fi
  52. }

  54. # 生出端口流出文件
  55. function _out(){
  56.     if [ -f "index.txt" ];then
  57.         cp ./index.txt out.txt
  58.        
  59.         #SNMP v1
  60.         if [ $version == "v1" ];then
  61.             sed -i "s/IF-MIB::ifDescr/IF-MIB::ifOutOctets/g" `grep IF-MIB::ifDescr -rl out.txt `
  62.         fi
  63.       
  64.         #SNMP v2c
  65.         if [ $version == "v2c" ];then
  66.             sed -i "s/IF-MIB::ifDescr/IF-MIB::ifHCOutOctets/g" `grep IF-MIB::ifDescr -rl out.txt `
  67.         fi

  69.     else
  70.         echo "not index.txt"
  71.     fi

  73. }

  75. # 外部参数
  76. parameter=$1
  77. community=$3
  78. version=$2
  79. ip=$4

  81. # 参数使用
  82. case $parameter in
  83.     "index")
  84.          index $2 $3 $4 $a
  85.     ;;
  86.     "port")
  87.          port $2 $3 $4 $a
  88.     ;;
  89.     "del")
  90.          del
  91.     ;;
  92.     "in")
  93.          _in $2
  94.     ;;
  95.     "out")
  96.          _out $2
  97.     ;;
  98.     *)
  99.         echo ""
  100.         echo "Usage: {$0 Verison Community Parameter Ip}"
  101.         echo "Parameter: {index|port|del|in|out}"
  102.         echo "Community: {Public}"
  103.         echo "Example: {$0 index v1 Public 202.206.33.37}"
  104.         echo ""
  105.     ;;
  106. esac
insert_snmp_oid.php

点击(此处)折叠或打开

  1. #!/opt/lampp/bin/php
  2. <?php
  3. /*
  4.     使用方法
  5.     chmo +x ./inster_snmp_oid.php
  6.     ./inster_snmp_oid.php v1 stdu.edu.cn_nmc 202.206.32.42
  7. */

  9. /* var */
  10. @@$Version = $argv[1];
  11. @@$Community = $argv[2];
  12. @@$IP = $argv[3];
  13. @@$Factory = $argv[4];

  15. if(isset($Version) && isset($Community) && isset($IP)){
  16.     echo "生成中\n";
  17. }else{
  18.     echo "参数格式:版本,社区名,IP地址\n";
  19.         echo "例子:./inster_snmp_oid.php v1 stdu.edu.cn_nmc 202.206.32.42\n";
  20.     exit;
  21. }

  23. /* PDO mysql */
  24. $pdo = new PDO('mysql:host=202.206.32.218;dbname=test1', 'root', 'zsdsywr.');
  25. $pdo->exec('set names utf8');
  26. $pdo->exec('TRUNCATE TABLE `snmp_oid`');

  28. /* Config */
  29. $Parameter_1 = "index";
  30. $Parameter_2 = "port";
  31. $Parameter_3 = "in";
  32. $Parameter_4 = "out";

  34. /* Shell Script */
  35. function shell($Parameter_1,$Parameter_2,$Parameter_3,$Parameter_4,$Version,$Community,$IP){
  36.    exec("./snmpwalk.sh $Parameter_1 $Version $Community $IP");
  37.    exec("./snmpwalk.sh $Parameter_2 $Version $Community $IP");
  38.    exec("./snmpwalk.sh $Parameter_3 $Version $Community $IP");
  39.    exec("./snmpwalk.sh $Parameter_4 $Version $Community $IP");
  40. }

  42. /* Run Shell */
  43. shell($Parameter_1,$Parameter_2,$Parameter_3,$Parameter_4,$Version,$Community,$IP);

  45. /* Shell Add Files */
  46. $file_index = 'index.txt';
  47. $file_port ='port.txt';
  48. $file_in = 'in.txt';
  49. $file_out = 'out.txt';

  51. /* File Array */
  52. $index = file($file_index);
  53. $port = file($file_port);
  54. $in = file($file_in);
  55. $out = file($file_out);

  57. $sql ="INSERT INTO `snmp_oid`(`ID`,`IP`,`COMMUNITY`,`VERSION`,`OID_index`,`OID_port`,`OID_in`,`OID_out`) VALUES";

  59. foreach ($index as $value1){
  60.    $value2 = current($port);
  61.    $value3 = current($in);
  62.    $value4 = current($out);
  63.  
  64.    $new[] = array("$value1","$value2","$value3","$value4");
  65.    next($port);
  66.    next($in);
  67.    next($out);
  68. }

  70. foreach($new as $value => $key){
  71.   #print_r($key);
  72.   $sql .= "(NULL, '$IP', '$Community', '$Version', '$key[0]','$key[1]','$key[2]','$key[3]'),";
  73. }

  75. $SQL = rtrim($sql,',');
  76. $new_sql = $SQL.";";

  78. $inster = $pdo->exec("$new_sql");

  80. exec("./snmpwalk.sh del");
  81. if($inster == true){
  82.    echo "insert success\n";
  83. }else{
  84.     echo "inster error\n";
  85. }
zbx.inc.php

点击(此处)折叠或打开

  1. <?php
  2. class jsonrpc{
  3.     
  4.     protected function connect($server, $query){
  5.         $http = curl_init($server);
  6.         curl_setopt($http, CURLOPT_CUSTOMREQUEST, 'POST');
  7.         curl_setopt($http, CURLOPT_POSTFIELDS, $query);
  8.         curl_setopt($http, CURLOPT_RETURNTRANSFER, TRUE);
  9.         curl_setopt($http, CURLOPT_SSL_VERIFYPEER, FALSE);
  10.         /* curl_setopt($http, CURLOPT_PROXY, 'proxy_url');
  11.         curl_setopt($http, CURLOPT_PROXYPORT, '3128');
  12.         curl_setopt($http, CURLOPT_PROXYUSERPWD, 'login:pass'); */
  13.         curl_setopt($http, CURLOPT_SSL_VERIFYHOST, FALSE);
  14.         curl_setopt($http, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
  15.         $response = curl_exec($http);
  16.         return json_decode($response, true);
  17.         curl_close($http);
  18.     }
  19.     
  20. }


  23. class zbx extends jsonrpc{

  25.     public $method;
  26.     public $access_token;
  27.     public $url;
  28.     public $query;

  30.     function call(){
  31.         $data['jsonrpc'] = '2.0';
  32.         $data['method'] = $this->method;
  33.         $data['params'] = $this->query;
  34.         $this->query = '';
  35.         if(!empty($this->access_token))
  36.         $data['auth'] = $this->access_token;
  37.         $data['id'] = rand(1,100);
  38.         $data = json_encode($data, JSON_PRETTY_PRINT);
  39.         return $this->connect($this->url, $data);
  40.     }
  41.         
  42. }
zbx.templates.class.php

点击(此处)折叠或打开

  1. #!/opt/lampp/bin/php
  2. <?php
  3. /**
  4. *交换机snmp模板创建
  5. *
  6. *用于创建zabbix模板的items trigger
  7. * @author kingsh2012@163.com
  8. */

  10. /* Import Zabbix API */
  11. require __DIR__ . '/zbx.inc.php';


  14. class ZabbixTemplates{
  15.     
  16.     /**
  17.     * 构造函数
  18.     * 负责zabbix API调用，与32.218数据库的PDO方式连接。
  19.     *
  20.     * @return $this->zbx;
  21.     * @return $this->pdo;
  22.     */
  23.     function __construct() {
  24.         // zabbix API import
  25.         $this->zbx = new zbx;
  26.         $this->zbx->url = "http://202.206.32.203/api_jsonrpc.php";        //网页地址
  27.         $this->zbx->method = 'user.login';                                
  28.         $this->zbx->query['user'] = 'api';                                //用户名管理员
  29.         $this->zbx->query['password'] = 'zabbix';                        //密码            
  30.         $this->zbx->access_token = $this->zbx->call()['result'];

  32.         // connect 202.206.32.218 databases
  33.         try {
  34.             $this->pdo = new PDO("mysql:host=202.206.32.218;dbname=test1", "root", "zsdsywr.");        //数据库连接
  35.             $this->pdo->exec('set names utf8');
  36.             $sql = "SELECT * FROM `snmp_oid` ";
  37.             // $sql = "SELECT * FROM `items_plus` ";
  38.             $this->snmp = $this->pdo->query($sql);
  39.             }catch (PDOException $e) {
  40.                 exit($e->getMessage());
  41.             }
  42.     }
  43.     
  44.     
  45.     /**
  46.     * GetTemplateID
  47.     * 获取模板ID
  48.     *
  49.     * @access public
  50.     * @param string $name 模板名称
  51.     * @return integer
  52.     */
  53.     function GetTemplateID ($name) {
  54.         $this->zbx->method = 'template.get';
  55.         $this->zbx->query['output'] = 'extend';
  56.         $this->zbx->query['filter']['host'] = "$name";
  57.         @$templateid = $this->zbx->call()['result'][0]['templateid'];
  58.         if(!empty($templateid)){
  59.             return $templateid;
  60.         }else{
  61.             echo "输入主机错误";
  62.         }
  63.     }
  64.     
  65.     /**
  66.     * GetHostID
  67.     * 获取主机ID
  68.     *
  69.     * @access public
  70.     * @param string $host 主机名称
  71.     * @return integer
  72.     */
  73.     function GetHostID ($host) {
  74.         $this->zbx->method = 'host.get';
  75.         $this->zbx->query['output'] = 'extend';
  76.         $this->zbx->query['filter']['host'] = "$host";
  77.         $hostid = $this->zbx->call();
  78.         return $hostid;
  79.     }
  80.     
  81.     /**
  82.     * GetApplicationID
  83.     * 获取应用ID
  84.     *
  85.     * @access 调试
  86.     */     
  87.     function GetApplicationID(){
  88.         $this->zbx->method = 'application.get';
  89.         $this->zbx->query['output'] = 'extend';
  90.         $this->zbx->query['hostids']['host'] = "11562";
  91.         $result = $this->zbx->call();
  92.         print_r($result);
  93.     }
  94.     
  95.     /**
  96.     * DeltetItem
  97.     * 删除items
  98.     *
  99.     * @access 调试
  100.     */     
  101.     function DeltetItem(){
  102.         // $i = 0;
  103.         // foreach($this->snmp as $key => $value ){
  104.             // $itmsids = $value["itemids"];
  105.             // echo $itmsids;
  106.             // exit;
  107.             $this->zbx->method = 'item.delete';
  108.             // $this->zbx->query = ["$itmsids"];
  109.             $this->zbx->query = ['85668'];
  110.             $result = $this->zbx->call();
  111.             print_r($result);
  112.             // echo $i++."\n";
  113.             // print_r($value);
  114.             // echo $value["itemids"];
  115.         // }
  116.     }
  117.     
  118.     /**
  119.     * GetHostID
  120.     * 获取主机ID
  121.     *
  122.     * @access public
  123.     * @param string $host 主机名称
  124.     * @return integer
  125.     */
  126.     function GetGroupID($GroupNmae){
  127.         $this->zbx->method = 'hostgroup.get';
  128.         $this->zbx->query['output'] = 'extend';
  129.         $this->zbx->query['filter']['name'] = "$GroupNmae";
  130.         @$groupid = $this->zbx->call()['result']['0']['groupid'];
  131.         if(isset($groupid)){
  132.             return $groupid;
  133.         }else{
  134.             echo $GroupNmae . "你输入的组不存在\n";
  135.             exit;
  136.         }
  137.     }
  138.     
  139.     /**
  140.     * CreateTemplate
  141.     * 创建模板
  142.     *
  143.     * @access public
  144.     * @param string $GroupNmae 以存在的 组名称
  145.     * @param string $TemplateNmae 不存在的 模板名称
  146.     * @return integer
  147.     */
  148.     function CreateTemplate($GroupNmae,$TemplateNmae){
  149.         
  150.         $groupid = $this->GetGroupID($GroupNmae);
  151.         // echo $groupid;
  152.         // exit;
  153.         $this->zbx->method = 'template.create';
  154.         $this->zbx->query['host'] = "$TemplateNmae";
  155.         $this->zbx->query['groups']['groupid'] = "$groupid";
  156.         @$templateids = $this->zbx->call()['result']['templateids']['0'];
  157.         if(isset($templateids)){
  158.             return $templateids;
  159.         }else{
  160.             echo $TemplateNmae . "模板已经存在\n";
  161.             exit;
  162.         }
  163.     }
  164.     
  165.     /**
  166.     * CreateApplication
  167.     * 创建应用
  168.     * 这个很重要,在 Zabbix Latest data里面相当于items的分组
  169.     *
  170.     * @access public
  171.     * @param integer $hostid Application创建在哪个主机下面.主机ID
  172.     * @param integer $number 不同的数字对应着不同的Application名字
  173.     * @return integer
  174.     */
  175.     function CreateApplication($hostid,$number){
  176.         if($number == 1){
  177.             $name = '端口列队';
  178.         }elseif($number == 2){
  179.             $name = '端口单播包';
  180.         }elseif($number == 3){
  181.             $name = '端口多播包';
  182.         }elseif($number == 4){
  183.             $name = '端口广播包';
  184.         }elseif($number == 5){
  185.             $name = '端口描述';
  186.         }elseif($number == 6){
  187.             $name = '端口操作状态';
  188.         }elseif($number == 7){
  189.             $name = '端口流量';
  190.         }elseif($number == 8){
  191.             $name = '端口管理状态';
  192.         }elseif($number == 9){
  193.             $name = '端口错误包';
  194.         }elseif($number == 10){
  195.             $name = '端口非单播包';
  196.         }else{
  197.             echo "应用ID输入错误\n";
  198.             exit;
  199.         }
  200.         $this->zbx->method = 'application.create';
  201.         $this->zbx->query['name'] = "$name";
  202.         $this->zbx->query['hostid'] = "$hostid";
  203.         $applicationids = $this->zbx->call()['result']['applicationids']['0'];
  204.         return $applicationids;
  205.     }
  206.     
  207.     /**
  208.     * CreateItem
  209.     * 创建itme
  210.     *
  211.     * @access public
  212.     * @param integer $type                各种item的选择
  213.     * @param integer $hostid            主机ID
  214.     * @param string $items_name            名字
  215.     * @param string $snmp_version        snmp版本
  216.     * @param string $items_key            KEY
  217.     * @param string $items_oid            OID
  218.     * @param string $snmp_community        社区名
  219.     * @param string $applications        应用ID
  220.     * @param string $description        备注
  221.     * @return integer
  222.     */
  223.     function CreateItem($type, $hostid, $items_name, $snmp_version, $items_key, $items_oid, $snmp_community, $applications,$description){
  224.         // 数据包 双向OID
  225.         if($type == 0){
  226.             $this->zbx->method = 'item.create';
  227.             $this->zbx->query['hostid'] = "$hostid"; //主机号
  228.             $this->zbx->query['name'] = "$items_name"; //items名字
  229.             $this->zbx->query['type'] = "$snmp_version"; //snmp版本号
  230.             $this->zbx->query['key_'] = "$items_key"; //itmes值
  231.             $this->zbx->query['snmp_oid'] = "$items_oid"; //oid
  232.             $this->zbx->query['snmp_community'] = "$snmp_community"; //snmp社区
  233.             $this->zbx->query['port'] = '161'; //端口
  234.             $this->zbx->query['value_type'] = '3'; //3 - numeric unsigned; 数值 特殊
  235.             $this->zbx->query['delay'] = '60';
  236.             $this->zbx->query['applications'] = ["$applications"]; //应用ID
  237.             $this->zbx->query['history'] = '7'; //记录时间 天
  238.             $this->zbx->query['description'] = "$description"; //描述
  239.             $this->zbx->query['delta'] = '1'; //1 - Delta, speed per second; 特殊
  240.             $itemids = $this->zbx->call()['result']['itemids']['0'];
  241.             return $itemids;
  242.         }elseif($type == 1){
  243.             // 流量 双向OID 这个被单独拿了出来是因为流量的涉及到 单位换算 显示单位 差值
  244.             // 注意 其实这个流量生成不建议使用这个函数    有单独对流量做过完整脚本
  245.             $this->zbx->method = 'item.create';
  246.             $this->zbx->query['hostid'] = "$hostid";
  247.             $this->zbx->query['name'] = "$items_name";
  248.             $this->zbx->query['type'] = "$snmp_version";
  249.             $this->zbx->query['key_'] = "$items_key";
  250.             $this->zbx->query['snmp_oid'] = "$items_oid";
  251.             $this->zbx->query['snmp_community'] = "$snmp_community";
  252.             $this->zbx->query['port'] = '161';
  253.             $this->zbx->query['value_type'] = '3';
  254.             $this->zbx->query['delay'] = '60';
  255.             $this->zbx->query['applications'] = ["$applications"];
  256.             $this->zbx->query['history'] = '7';
  257.             $this->zbx->query['description'] = "$description";
  258.             $this->zbx->query['delta'] = '1';
  259.             $this->zbx->query['formula'] = '8'; //特殊
  260.             $this->zbx->query['multiplier'] = '1'; //特殊
  261.             $this->zbx->query['units'] = 'bps'; //特殊
  262.             $itemids = $this->zbx->call()['result']['itemids']['0'];
  263.             return $itemids;
  264.         }elseif($type == 2){
  265.             // 单项 OID
  266.             $this->zbx->method = 'item.create';
  267.             $this->zbx->query['hostid'] = "$hostid";
  268.             $this->zbx->query['name'] = "$items_name";
  269.             $this->zbx->query['type'] = "$snmp_version";
  270.             $this->zbx->query['key_'] = "$items_key";
  271.             $this->zbx->query['snmp_oid'] = "$items_oid";
  272.             $this->zbx->query['snmp_community'] = "$snmp_community";
  273.             $this->zbx->query['port'] = '161';
  274.             $this->zbx->query['value_type'] = '1'; //特殊
  275.             $this->zbx->query['delay'] = '60';
  276.             $this->zbx->query['applications'] = ["$applications"];
  277.             $this->zbx->query['history'] = '7';
  278.             $this->zbx->query['description'] = "$description";
  279.             $itemids = $this->zbx->call()['result']['itemids']['0'];
  280.             return $itemids;
  281.         }elseif($type == 3){
  282.             // 单项OID 管理状态 这个被单独拿了出来是因为"Show value"这个项,在官方的API里面没有找到怎么取这个值. Value mapping
  283.             // 这个item被创建以后返回值是 1-3 (1=up,2=down,3=testing)
  284.             $this->zbx->method = 'item.create';
  285.             $this->zbx->query['hostid'] = "$hostid";
  286.             $this->zbx->query['name'] = "$items_name";
  287.             $this->zbx->query['type'] = "$snmp_version";
  288.             $this->zbx->query['key_'] = "$items_key";
  289.             $this->zbx->query['snmp_oid'] = "$items_oid";
  290.             $this->zbx->query['snmp_community'] = "$snmp_community";
  291.             $this->zbx->query['port'] = '161';
  292.             $this->zbx->query['value_type'] = '1';
  293.             $this->zbx->query['delay'] = '60';
  294.             $this->zbx->query['applications'] = ["$applications"];
  295.             $this->zbx->query['history'] = '7';
  296.             $this->zbx->query['description'] = "$description";
  297.             $this->zbx->query['valuemapid'] = '11'; //特殊
  298.             $itemids = $this->zbx->call()['result']['itemids']['0'];
  299.             return $itemids;
  300.         }elseif($type == 4){
  301.             // 单项OID 操作状态 这个被单独拿了出来是因为"Show value"这个项,在官方的API里面没有找到怎么取这个值. Value mapping
  302.             // 这个item被创建以后返回值是 1-7 (1=up,2=down,3=testing,4=unknown,5=dormant,6=notPresent,7=lowerLayerDown)
  303.             $this->zbx->method = 'item.create';
  304.             $this->zbx->query['hostid'] = "$hostid";
  305.             $this->zbx->query['name'] = "$items_name";
  306.             $this->zbx->query['type'] = "$snmp_version";
  307.             $this->zbx->query['key_'] = "$items_key";
  308.             $this->zbx->query['snmp_oid'] = "$items_oid";
  309.             $this->zbx->query['snmp_community'] = "$snmp_community";
  310.             $this->zbx->query['port'] = '161';
  311.             $this->zbx->query['value_type'] = '1';
  312.             $this->zbx->query['delay'] = '60';
  313.             $this->zbx->query['applications'] = ["$applications"];
  314.             $this->zbx->query['history'] = '7';
  315.             $this->zbx->query['description'] = "$description";
  316.             $this->zbx->query['valuemapid'] = '8'; //特殊
  317.             $itemids = $this->zbx->call()['result']['itemids']['0'];
  318.             return $itemids;
  319.         }
  320.     }
  321.     
  322.     /**
  323.     * Usage_CreateTwoOID
  324.     * 执行函数 创建双OID
  325.     *
  326.     * @access public
  327.     * @param string $GroupNmae            组名称
  328.     * @param string $TemplateNmae        新建模板名称
  329.     * @param string $oid                OID
  330.     * @param integer $applications        应用ID
  331.     * @param integer $type                item类型选择
  332.     * @param string $description        描述
  333.     * @return integer
  334.     */
  335.     function Usage_CreateOneOID($GroupNmae, $TemplateNmae, $oid, $applications, $type, $description){
  336.         
  337.         if(!isset($GroupNmae) || !isset($TemplateNmae) || !isset($oid) || !isset($applications) || !isset($type) || !isset($description)){
  338.             echo "###################################################################################################\n";
  339.             echo "# 说明: \$a->Pkts('组名称','模板名称','oid','应用ID','类型ID','描述'); #\n";
  340.             echo "# 使用: \$a->Pkts('华为交换机2326模板','Switch_Quidway_S2326TP-EI','ifAlias',5,2,'端口描述'); #\n";
  341.             echo "# 创建应用ID: 输入1-10 #\n";
  342.             echo "# 对应关系: 5=端口描述;6=操作状态;8=管理状态 #\n";
  343.             echo "# 创建类型ID: 输入2-4 #\n";
  344.             echo "# 对应关系: 2=其他;3=管理状态;4=操作状态 #\n";
  345.             echo "###################################################################################################\n";
  346.             exit();
  347.         }
  348.         
  349.         $TemplateID = $this->CreateTemplate($GroupNmae,$TemplateNmae);
  350.         $ApplicationsID = $this->CreateApplication($TemplateID,$applications);
  351.         $oid_name = str_replace(array('if'), "",$oid);
  352.         
  353.         $insert_sql="INSERT INTO `items_plus`(`id`, `hostid`, `snmp_index`, `itemids`, `items_name`, `items_key`, `items_oid`, `ApplicationID`) VALUES ";

  355.         foreach($this->snmp as $key => $value ){

  357.             if($value['VERSION'] == 'v1'){
  358.                 $snmp_version = "1";
  359.             }elseif($value['VERSION'] == 'v2c'){
  360.                 $snmp_version = "4";
  361.             }
  362.             
  363.             $items = str_replace(array("\r\n", "\r", "\n"), "", $value['OID_port']);
  364.             $items_name = $items."_$oid_name";
  365.             $items_key = str_replace('/','_',$items_name);
  366.             $items_oid = str_replace('ifDescr',"$oid",$value['OID_index']);
  367.             $items_oid = str_replace(array("\r\n", "\r", "\n"), "", $items_oid);
  368.             
  369.             $itemids = $this->CreateItem($type, $TemplateID, $items_name, $snmp_version, $items_key, $items_oid, $value['COMMUNITY'], $ApplicationsID,$description);

  371.             $insert_sql .= "(NULL,'$TemplateID','$value[4]','$itemids','$items_name','$items_key','$items_oid','$ApplicationsID'),";
  372.         }
  373.         $insert_sql = rtrim($insert_sql,',');
  374.         $insert_sql = $insert_sql.";";
  375.         $this->pdo->exec("$insert_sql");
  376.     }
  377.     
  378.     /**
  379.     * Usage_CreateTwoOID
  380.     * 执行函数 创建双OID
  381.     *
  382.     * @access public
  383.     * @param string $GroupNmae            组名称
  384.     * @param string $TemplateNmae        新建模板名称
  385.     * @param string $InPkts                接收OID
  386.     * @param string $OutPkts            发送OID
  387.     * @param integer $type                选择item
  388.     * @param integer $applications        应用ID
  389.     * @param string $in_description        接收item描述
  390.     * @param string $out_description    发送item描述
  391.     * @return integer
  392.     */
  393.     function Usage_CreateTwoOID($GroupNmae, $TemplateNmae, $InPkts, $OutPkts, $type, $applications, $in_description,$out_description){

  395.         if(!isset($GroupNmae) || !isset($TemplateNmae) || !isset($InPkts) || !isset($OutPkts) || !isset($type) || !isset($applications) || !isset($in_description) || !isset($out_description)){
  396.             echo "###########################################################################################################################\n";
  397.             echo "# 说明: \$a->Pkts('组名称', '模板名称', '接收OID', '发送OID', '选择item', '应用ID', '接收OID描述', '发送OID描述'); #\n";
  398.             echo "# 使用: \$a->Pkts('华为交换机2326模板', 'Switch_Quidway_S2326TP-EI', 'ifInUcastPkts', 'ifOutUcastPkts', 0, 2, '单波包'); #\n";
  399.             echo "# type: 输入0-1 #\n";
  400.             echo "# 对应关系: 0=其他数据包差值,1=特指流量包; #\n";
  401.             echo "# 创建应用ID: 输入1-10 #\n";
  402.             echo "# 对应关系: 1=列队;2=单播包;3=多播包;4=广播包;9=错误包;10=非单播包; #\n";
  403.             echo "###########################################################################################################################\n";
  404.             exit();
  405.         }
  406.         
  407.         $TemplateID = $this->CreateTemplate($GroupNmae,$TemplateNmae);
  408.         $ApplicationsID = $this->CreateApplication($TemplateID,$applications);
  409.         
  410.         $InPkts_name = str_replace(array('ifIn'), "",$InPkts);
  411.         $OutPkts_name = str_replace(array('ifOut'), "",$OutPkts);
  412.         
  413.         $insert_sql="INSERT INTO `items_plus`(`id`, `hostid`, `snmp_index`, `itemids`, `items_name`, `items_key`, `items_oid`, `ApplicationID`) VALUES ";

  415.         foreach($this->snmp as $key => $value ){

  417.             if($value['VERSION'] == 'v1'){
  418.                 $snmp_version = "1";
  419.             }elseif($value['VERSION'] == 'v2c'){
  420.                 $snmp_version = "4";
  421.             }
  422.             
  423.             $items = str_replace(array("\r\n", "\r", "\n"), "", $value['OID_port']);
  424.             $items_in_name = $items."_in_$InPkts_name";
  425.             $items_in_key = str_replace('/','_',$items_in_name);
  426.             $items_in_oid = str_replace('ifDescr',"$InPkts",$value['OID_index']);
  427.             $items_in_oid = str_replace(array("\r\n", "\r", "\n"), "", $items_in_oid);

  429.             $items_out_name = $items."_out_$OutPkts_name";
  430.             $items_out_key = str_replace('/','_',$items_out_name);
  431.             $items_out_oid = str_replace('ifDescr',"$OutPkts",$value['OID_index']);
  432.             $items_out_oid = str_replace(array("\r\n", "\r", "\n"), "", $items_out_oid);
  433.             
  434.             $in_itemids = $this->CreateItem($type, $TemplateID, $items_in_name, $snmp_version, $items_in_key, $items_in_oid, $value['COMMUNITY'], $ApplicationsID,$in_description);
  435.             $out_itemids = $this->CreateItem($type, $TemplateID, $items_out_name, $snmp_version, $items_out_key, $items_out_oid, $value['COMMUNITY'], $ApplicationsID,$out_description);

  437.             $insert_sql .= "(NULL,'$TemplateID','$value[4]','$in_itemids','$items_in_name','$items_in_key','$items_in_oid','$ApplicationsID'),";
  438.             $insert_sql .= "(NULL,'$TemplateID','$value[4]','$in_itemids','$items_out_name','$items_out_key','$items_out_oid','$ApplicationsID'),";
  439.         }
  440.         $insert_sql = rtrim($insert_sql,',');
  441.         $insert_sql = $insert_sql.";";
  442.         $this->pdo->exec("$insert_sql");
  443.     }
  444.     
  445.     /**
  446.     * CreateTrigger
  447.     * 这个函数是创建触发器,但只是创建接收NUcastPkts的触发器
  448.     * 预防广播风暴
  449.     *
  450.     * @access public
  451.     * @param string $HostName            模板名称
  452.     * @return
  453.     */
  454.     function CreateTrigger($HostName){
  455.         $Macros1_1 = '{$NUCASTPKTS_VALUE1}';
  456.         $Macros1_2 = '{$NUCASTPKTS_VALUE2}';
  457.         $Macros1_3 = '{$NUCASTPKTS_VALUE3}';
  458.         $Macros2 = '{$NUCASTPKTS_NAME_HEAD}';
  459.         $Macros3 = '{$NUCASTPKTS_NAME_TAIL}';
  460.         $HostID = $this->GetTemplateID($HostName);
  461.         $sql = "SELECT * FROM `items_plus` WHERE `hostid` = $HostID AND `items_key` LIKE '%in%'";
  462.         $this->items = $this->pdo->query($sql);
  463.         
  464.         $i = 1;
  465.         foreach($this->items as $key => $value ){
  466.             $description_name = str_replace(array("\r\n", "\r", "\n"), "", $value['items_name']);
  467.             $description_name = str_replace(array('_in_NUcastPkts'), "",$description_name);
  468.             // print_r($description_name);
  469.             
  470.             $this->zbx->method = 'trigger.create';
  471.             $this->zbx->query['description'] = $Macros2 . ' ' . $description_name . " > " . $Macros1_1 .' '. $Macros3;
  472.             $this->zbx->query['expression'] = '{' . $HostName . ':' . $value['items_key'] . ".last(#5)" . '}>' . $Macros1_1;
  473.             $this->zbx->query['priority'] = '1';
  474.             $result1 = $this->zbx->call();
  475.             
  476.             $this->zbx->method = 'trigger.create';
  477.             $this->zbx->query['description'] = $Macros2 . ' ' . $description_name . " > " . $Macros1_2 .' '. $Macros3;
  478.             $this->zbx->query['expression'] = '{' . $HostName . ':' . $value['items_key'] . ".last(#5)" . '}>' . $Macros1_2;
  479.             $this->zbx->query['priority'] = '2';
  480.             $result2 = $this->zbx->call();
  481.             
  482.             $this->zbx->method = 'trigger.create';
  483.             $this->zbx->query['description'] = $Macros2 . ' ' . $description_name . " > " . $Macros1_3 .' '. $Macros3;
  484.             $this->zbx->query['expression'] = '{' . $HostName . ':' . $value['items_key'] . ".last(#5)" . '}>' . $Macros1_3;
  485.             $this->zbx->query['priority'] = '3';
  486.             $result3 = $this->zbx->call();
  487.             echo $i++."\n";
  488.         }
  489.     }
  490. }
  491. ?>
usage.php

点击(此处)折叠或打开

  1. #!/opt/lampp/bin/php
  2. <?php
  3. require __DIR__ . '/zbx.templates.class.php';
  4. $ZabbixTemplates = new ZabbixTemplates;
  5. # 华为2326交换机
  6. // $ZabbixTemplates->Usage_CreateOneOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_Alias','ifAlias',5,2,'端口描述');
  7. // $ZabbixTemplates->Usage_CreateOneOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_AdminStatus','ifAdminStatus',8,3,'端口管理状态');
  8. // $ZabbixTemplates->Usage_CreateOneOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_OperStatus','ifOperStatus',6,4,'端口操作状态');
  9. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_NUcastPkts','ifInNUcastPkts','ifOutNUcastPkts',0,10,'接收非单波包','发送非单波包');
  10. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_Errors','ifInErrors','ifOutErrors',0,9,'接收错误包','发送错误包');
  11. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_MulticastPkts','ifInMulticastPkts','ifInMulticastPkts',0,3,'接收多波包','发送多波包');
  12. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_UcastPkts','ifInUcastPkts','ifOutUcastPkts',0,2,'接收单波包','发送单波包');
  13. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_BroadcastPkts','ifInBroadcastPkts','ifOutBroadcastPkts',0,4,'接收广波包','发送广波包');
  14. // $ZabbixTemplates->Usage_CreateTwoOID('华为交换机2326模板','Switch_Quidway_S2326TP-EI_QLen','ifInQLen','ifOutQLen',0,1,'接收列队','发送列队');
  15. // $ZabbixTemplates->CreateTrigger('Switch_Quidway_S2326TP-EI_NUcastPkts');
注意：
       insert_snmp_oid.php这个文件是操作文件，用来生成SNMP信息。
      usage.php这个文件是导入的操作文件。这个导入只能一次一个的执行这个文件来完成。不能同时导入多个。上边有10个导入，就得执行10次这个文件。
       本人是这样用的，第一开个putty的SSH客户端，打开一个可以支持sftp的编辑器notepad++，putty创建文件加入操作权限，通过notepad++连接centos进行编辑修改。
      为什么要创建这么多的模板？模板关联模板自己想吧。 
      最后的那个itmes_plus表是干什么用的？ 存itemids有了这个id，后期再写trigger 和 graphs就比较容易了。
      其实那些OID都是用的OID名字，zabbix支持这种写法。
       为什么TMD用PHP写？因为目前我就会点这语言，以后会重新写成PYTHON的。


阅读(5473) | 评论(0) | 转发(0) |
0

上一篇：华为交换机 清空回收站

下一篇：[Warning] TIMESTAMP with implicit DEFAULT value is deprecated. Please use

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6