Chinaunix首页 | 论坛 | 博客

Kingsh2012 ChinaUnixBlog

首页　| 　博文目录　| 　关于我

kingsh2012

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

.....

文章分类

全部博文（32）

文章存档

2016年（1）

2015年（12）

2014年（19）

我的朋友
最近访客
推荐博文
相关博文
zabbix监控交换机端口流量_脚本,自动出图

分类： 系统运维

2015-04-16 00:49:55

通过使用snmpwalk命令得到端口流量信息，写入数据库，创建创建XML文件API导入Zbx，实现自动创建主机并创建items，自动出图。

目录结构
./
├── run.sh                       # 1.执行程序 
├── snmpwalk.sh              # 2.snmpwalk 主要 执行snmpwalk命令得到索引，端口，流入，流出信息保存成txt文件
├── insert_snmp_oid.php  # 2.读取txt文件将文件内容写入MYSQL
├── create_host.php         # 3.读取MYSQL，将OID信息拼成XML文件，在通过api导入
├── xml/                         # 5. XML保存在这
└── zbx.inc.php

使用方法
   添加可执行权限
    chmod +x star.sh snmpwalk.sh  inster_snmp_oid.php create_host.php
   执行./star.sh 程序会有提示，写入什么参数。

MYSQL表
创建 test1 数据库 

点击(此处)折叠或打开

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

脚本内容
    zbx.inc.php       #  ZBX API
   star.sh

点击(此处)折叠或打开

  1. #!/bin/bash
  2. ./insert_snmp_oid.php $1 $2 $3
  3. echo "-------------------------------------------"
  4. ./create_host.php $3
    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
    inster_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 "厂家:hw,rj\n";
  20.         echo "例子:./inster_snmp_oid.php v1 stdu.edu.cn_nmc 202.206.32.42 hw\n";
  21.     exit;
  22. }

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

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

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

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

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

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

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

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

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

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

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

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

点击(此处)折叠或打开

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

  9. /* Zabbix API */
  10. require __DIR__ . '/zbx.inc.php';
  11. include ("/opt/wwwroot/db.php");
  12. $zbx = new zbx;

  14. /* 设置变量 */
  15. @@$ip = $argv[1];
  16. if(isset($ip)){
  17.     echo "生成中\n";
  18. }else{
  19.     #echo "参数格式:IP地址\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');

  27. /* Zabbix组 */
  28. $group = "办公区楼宇 核心交换机";

  30. /* XML 文件存放位置 */
  31. $save = "./xml/$ip.xml";

  33. /* Zabbix token */
  34. $zbx->url = "";
  35. $zbx->method = 'user.login';
  36. $zbx->query['user'] = 'api';
  37. $zbx->query['password'] = 'zabbix';
  38. $zbx->access_token = $zbx->call()['result'];

  40. /* 生成XML文件函数 */
  41. function XML($pdo,$ip,$group,$save){
  42.     
  43.     // 查询 执行
  44.     $sql = "SELECT * FROM `snmp_oid` WHERE `IP` = '$ip'";
  45.     $result = $pdo -> query($sql);
  46.     $result_2 = $pdo -> query($sql);

  48.     // XML 头
  49.             $xml = "";
  50.             $xml.= "";
  51.             $xml.= "2.0";
  52.             $xml.= "2013-11-25T02:13:46Z";
  53.             $xml.= "".$group."";
  54.             $xml.="";
  55.             $xml.="".$ip."";
  56.             $xml.="".$ip."";
  57.             $xml.=<<<EOF
  58.                         <proxy>
  59.                              <name>Zabbix proxy 32.236</name>
  60.                         </proxy>
  61.                         <status>0</status>
  62.                         <ipmi_authtype>-1</ipmi_authtype>
  63.                         <ipmi_privilege>2</ipmi_privilege>
  64.                         <ipmi_username/>
  65.                         <ipmi_password/>
  66.                         <templates/>
  67.                         <groups>
  68.                             <group>
  69. EOF;
  70.                                 $xml.="".$group."";
  71.                             $xml.=<<<EOF
  72.                             </group>
  73.                         </groups>
  74.                         <interfaces>
  75.                             <interface>
  76.                                 <default>1</default>
  77.                                 <type>2</type>
  78.                                 <useip>1</useip>
  79. EOF;
  80.                                 $xml.="".$ip."";
  81.                                 $xml.=<<<EOF
  82.                                 <dns/>
  83.                                 <port>161</port>
  84.                                 <interface_ref>if1</interface_ref>
  85.                             </interface>
  86.                         </interfaces>
  87.                         <applications/>
  88.                         <items>
  89. EOF;
  90.     /* 创建item */
  91.     foreach($result as $key => $value){
  92.         $community = $value['COMMUNITY'];
  93.         $oid_in = str_replace(array("\r\n", "\r", "\n"), "", $value['OID_in']);
  94.         $oid_out = str_replace(array("\r\n", "\r", "\n"), "", $value['OID_out']);
  95.         
  96.         if($value['VERSION'] == 'v1'){
  97.             $snmp_version = "1";
  98.         }elseif($value['VERSION'] == 'v2c'){
  99.             $snmp_version = "4";
  100.         }
  101.         
  102.         /* Items KEY */
  103.         $port = str_replace(array("\r\n", "\r", "\n"), "", $value['OID_port']);
  104.         $port_in_name = $port."_in";
  105.         $port_out_name = $port."_out";
  106.         $port_in_key = str_replace('/','_',$port_in_name);
  107.         $port_out_key = str_replace('/','_',$port_out_name);
  108.         
  109.                     $xml.="";
  110.                     $xml.="".$port_in_name."";
  111.                     $xml.="".$snmp_version."".$community."1";
  112.                     #$xml.="interfaces.ifTable.ifEntry.".$oid_in."";
  113.                     $xml.="".$oid_in."";
  114.                     $xml.="".$port_in_key."";
  115.                     $xml.=<<<EOF
  116.                                 <delay>60</delay>
  117.                                 <history>90</history>
  118.                                 <trends>365</trends>
  119.                                 <status>0</status>
  120.                                 <value_type>3</value_type>
  121.                                 <allowed_hosts/>
  122.                                 <units>bps</units>
  123.                                 <delta>1</delta>
  124.                                 <snmpv3_contextname/>
  125.                                 <snmpv3_securityname/>
  126.                                 <snmpv3_securitylevel>0</snmpv3_securitylevel>
  127.                                 <snmpv3_authprotocol>0</snmpv3_authprotocol>
  128.                                 <snmpv3_authpassphrase/>
  129.                                 <snmpv3_privprotocol>0</snmpv3_privprotocol>
  130.                                 <snmpv3_privpassphrase/>
  131.                                 <formula>8</formula>
  132.                                 <delay_flex/>
  133.                                 <params/>
  134.                                 <ipmi_sensor/>
  135.                                 <data_type>0</data_type>
  136.                                 <authtype>0</authtype>
  137.                                 <username/>
  138.                                 <password/>
  139.                                 <publickey/>
  140.                                 <privatekey/>
  141.                                 <port>161</port>
  142.                                 <description/>
  143.                                 <inventory_link>0</inventory_link>
  144.                                 <applications/>
  145.                                 <valuemap/>
  146.                                 <interface_ref>if1</interface_ref>
  147.                             </item>
  148. EOF;
  149.                     $xml.="";
  150.                     $xml.="".$port_out_name."";
  151.                     $xml.="".$snmp_version."".$community."1";
  152.                     #$xml.="interfaces.ifTable.ifEntry.".$oid_out."";
  153.                     $xml.="".$oid_out."";
  154.                     $xml.="".$port_out_key."";
  155.                     $xml.=<<<EOF
  156.                                 <delay>60</delay>
  157.                                 <history>90</history>
  158.                                 <trends>365</trends>
  159.                                 <status>0</status>
  160.                                 <value_type>3</value_type>
  161.                                 <allowed_hosts/>
  162.                                 <units>bps</units>
  163.                                 <delta>1</delta>
  164.                                 <snmpv3_contextname/>
  165.                                 <snmpv3_securityname/>
  166.                                 <snmpv3_securitylevel>0</snmpv3_securitylevel>
  167.                                 <snmpv3_authprotocol>0</snmpv3_authprotocol>
  168.                                 <snmpv3_authpassphrase/>
  169.                                 <snmpv3_privprotocol>0</snmpv3_privprotocol>
  170.                                 <snmpv3_privpassphrase/>
  171.                                 <formula>8</formula>
  172.                                 <delay_flex/>
  173.                                 <params/>
  174.                                 <ipmi_sensor/>
  175.                                 <data_type>0</data_type>
  176.                                 <authtype>0</authtype>
  177.                                 <username/>
  178.                                 <password/>
  179.                                 <publickey/>
  180.                                 <privatekey/>
  181.                                 <port>161</port>
  182.                                 <description/>
  183.                                 <inventory_link>0</inventory_link>
  184.                                 <applications/>
  185.                                 <valuemap/>
  186.                                 <interface_ref>if1</interface_ref>
  187.                             </item>
  188. EOF;
  189.     }
  190. $xml.=<<<EOF
  191.                         </items>
  192.                         <discovery_rules/>
  193.                         <macros/>
  194.                         <inventory/>
  195.                     </host>
  196.                 </hosts>
  197.                 <graphs>
  198. EOF;
  199.     /* 创建 graph */
  200.     foreach($result_2 as $key_2 => $value_2){
  201.   
  202.         /* Items KEY */
  203.         $graph_port = str_replace(array("\r\n", "\r", "\n"), "", $value_2['OID_port']);
  204.         
  205.         $graph_port_in_name = $graph_port."_in";
  206.         $graph_port_out_name = $graph_port."_out";
  207.         $graph_port_in_key = str_replace('/','_',$graph_port_in_name);
  208.         $graph_port_out_key = str_replace('/','_',$graph_port_out_name);

  210.           $xml.="";
  211.                  $xml.="$graph_port";
  212.                  $xml.=<<<EOF
  213.                         <width>900</width>
  214.                         <height>200</height>
  215.                         <yaxismin>0.0000</yaxismin>
  216.                         <yaxismax>100.0000</yaxismax>
  217.                         <show_work_period>1</show_work_period>
  218.                         <show_triggers>1</show_triggers>
  219.                         <type>0</type>
  220.                         <show_legend>1</show_legend>
  221.                         <show_3d>0</show_3d>
  222.                         <percent_left>0.0000</percent_left>
  223.                         <percent_right>0.0000</percent_right>
  224.                         <ymin_type_1>0</ymin_type_1>
  225.                         <ymax_type_1>0</ymax_type_1>
  226.                         <ymin_item_1>0</ymin_item_1>
  227.                         <ymax_item_1>0</ymax_item_1>
  228.                         <graph_items>
  229.                             <graph_item>
  230.                                 <sortorder>0</sortorder>
  231.                                 <drawtype>0</drawtype>
  232.                                 <color>00C800</color>
  233.                                 <yaxisside>0</yaxisside>
  234.                                 <calc_fnc>2</calc_fnc>
  235.                                 <type>0</type>
  236.                                 <item>
  237. EOF;
  238.                              $xml.="$ip";
  239.                              $xml.="$graph_port_in_key";
  240.                              $xml.=<<<EOF
  241.                                 </item>
  242.                             </graph_item>
  243.                             <graph_item>
  244.                                 <sortorder>1</sortorder>
  245.                                 <drawtype>0</drawtype>
  246.                                 <color>C80000</color>
  247.                                 <yaxisside>0</yaxisside>
  248.                                 <calc_fnc>2</calc_fnc>
  249.                                 <type>0</type>
  250.                                 <item>
  251. EOF;
  252.                                     $xml.="$ip";
  253.                                     $xml.="$graph_port_out_key";
  254.                                 $xml.=<<<EOF
  255.                                 </item>
  256.                             </graph_item>
  257.                         </graph_items>
  258.                     </graph>
  259. EOF;
  260.     }
  261. $xml .= <<<EOF
  262.                 </graphs>
  263.             </zabbix_export>
  264. EOF;
  265.         // 创建 XML 文件
  266.         $of = fopen($save,'w');//创建并打开文件
  267.         if($of){
  268.             fwrite($of,$xml);//把执行文件的结果写入文件
  269.             echo "Create XML success\n";
  270.         }else{
  271.             echo "XML write Error\n";
  272.         }

  274. }

  276. /* Zbx import API */
  277. function import($zbx,$save,$ip){
  278.     // 文件存入
  279.     $f = fopen ($save, "r");
  280.     $source = stream_get_contents($f);
  281.     fclose ($f);
  282.     
  283.     $zbx->method = 'configuration.import';
  284.     $zbx->query['format'] = 'xml';
  285.     $zbx->query['rules']['groups'] = array(
  286.                     "createMissing"=> true
  287.     );
  288.     $zbx->query['rules']['hosts'] = array(
  289.                     "createMissing"=> true,
  290.                     "updateExisting"=> true
  291.     );
  292.     $zbx->query['rules']['items'] = array(
  293.                     "createMissing"=> true,
  294.                     "updateExisting"=> true
  295.     );
  296.     $zbx->query['rules']['graphs'] = array(
  297.                     "createMissing"=> true,
  298.                     "updateExisting"=> true
  299.     );
  300.     $zbx->query['source'] = "$source";
  301.     $import = $zbx->call()['result'];
  302.     #print_r($import);
  303.     if($import == 1){
  304.         echo "$ip host import secuess!\n";
  305.     }else{
  306.         echo "$ip host import error!\n";
  307.     }
  308. }


  311. XML($pdo,$ip,$group,$save);
  312. import($zbx,$save,$ip);






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

上一篇：hawei 9306 snmp 详细oid

下一篇：linux下编译的PHP 添加soap扩展

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

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

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

16024965号-6