zabbix -- 一键安装2.4.7客户端 (附：邮件、微信警报)
小Q：各位，最近一直在玩zabbix，写点总结。1、搭建安装脚本，一键安装2.4.7 客户端
2、报警脚本（微信 邮件）
----------------------------------------------------------------------------------------------
1、搭建安装脚本，一键安装2.4.7 客户端
a、首先要找一台原始服务器，放置zabbix_2.4.7安装包，和一个已经写好适合自己的配置文件。
b、脚本如下
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
#!/bin/bash
function install_zabbix
{
mkdir /downloads
cd /downloads
wget http://ip/zabbix-2.4.7.tar.gz
##配置一个服务器端的zabbix安装包
tar zxf zabbix-2.4.7.tar.gz
cd /downloads/zabbix-2.4.7
./configure --prefix=/usr --sysconfdir=/etc/zabbix --enable-agent
make
make install
cp misc/init.d/fedora/core/zabbix_agentd /etc/init.d/
sed -i "s#BASEDIR=/usr/local#BASEDIR=/usr/#g" /etc/init.d/zabbix_agentd
groupadd zabbix -g 201
useradd -g zabbix -u 201 -m zabbix
mkdir /var/log/zabbix
mkdir /var/run/zabbix
chown zabbix.zabbix /var/log/zabbix
chown zabbix:zabbix /var/run/zabbix
chmod 755 /etc/init.d/zabbix_agentd
cd /etc/zabbix
mv /etc/zabbix/zabbix_agentd.conf /etc/zabbix/zabbix_agentd.conf.bak
wget http://IP/zabbix_agentd.conf
##自定义配置文件并配置在某服务器
#cd /usr/lib64
#ln -s /usr/local/lib/libiconv.so.2 ./
#ldconfig
/etc/init.d/zabbix_agentd start
}
install_zabbix
c、zabbix_agentd.conf文件如下
1
2
3
4
5
6
7
8
9
10
11
12
13
14
LogFile=/var/log/zabbix/zabbix_agentd.log
PidFile=/var/run/zabbix/zabbix_agentd.pid
EnableRemoteCommands=0
Server=127.0.0.1,10.47.67.163
StartAgents=8
Hostname=clientname
ServerActive=10.47.67.163:10051
Timeout=30
Include=/etc/zabbix/zabbix_agentd.conf.d/
UnsafeUserParameters=1
UserParameter=mysql.ping,/usr/local/mysql/bin/mysqladmin -uroot ping|grep -c alive
UserParameter=mysql.version,mysql -V | cut -f6 -d " "| sed 's/,//'
UserParameter=custom.vfs.dev.read.sectors[*],cat /proc/diskstats | grep vda | head -1 | awk '{print $$6}'
UserParameter=custom.vfs.dev.write.sectors[*],cat /proc/diskstats | grep vda | head -1 | awk '{print $$10}'
2、报警脚本（微信 邮件）
-----------------------------------------------------------放置地址在配置文件中定义
--------------------------------------------------------------------weixin
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
#!/usr/local/php/bin/php
<?php
error_reporting(E_ALL);
ini_set("display_errors", true);
class SdkQywx
{
const CORPID = 'wx1b71f3b1c380ce02';
const CORP_SECRET = 'S8-ZDuwiPipX0YQWs_xF9c4P6drWw08Z1MV0e_TgReTtYpn-4dqhBglthztHdFio';
public static $_app_list = array(
// 'gonggaotongzhi' => 34,
// 'kaoqinxitong' => 35,
// 'huiyixitong' => 36,
'm_monitor' => 43,
);
const IMAGE = 'image';
const VOICE = 'voice';
const VIDEO = 'video';
const FILE= 'file';
public static $tmpConnections;
private static $_access_token;
private static $expire_on = 0;
private $access_token;
//阻止外部实例化，仅允许使用getInstance进行单例操作
private function __construct($access_token)
{
$this->access_token = $access_token;
}
//防止对象被复制
public function __clone()
{
trigger_error('Clone is not allowed !');
}
/**
* 获取单例
*
* @return <Object>
*/
public static function getInstance()
{
$access_token = self::fetchAccessToken();
if (!isset(self::$tmpConnections[$access_token]) || !(self::$tmpConnections[$access_token] instanceof self))
{
// 清空连接池
self::$tmpConnections = array();
// 缓存新连接
self::$tmpConnections[$access_token] = new self($access_token);
}
return self::$tmpConnections[$access_token];
}
private static function fetchAccessToken()
{
// 检查连接令牌是否超时
if (self::$expire_on <= time())
{
// 调用接口获取连接令牌
$result = self::doGet('https://qyapi.weixin.qq.com/cgi-bin/gettoken', array(
'corpid' => self::CORPID,
'corpsecret' => self::CORP_SECRET,
));
// 校验结果
if (isset($result['errcode']))
{
return null;
}
// 缓存令牌
self::$expire_on = time() + $result['expires_in'];
self::$_access_token = $result['access_token'];
}
return self::$_access_token;
}
public function sendNewsMessage($agentid, $user_id, $content)
{
$url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send';
$params = array('access_token' => $this->access_token);
if (is_array($user_id))
{
$user_id = implode('|', $user_id);
}
$agentid= (int) $agentid;
$articles = '[';
$tips = '';
foreach ($content as $article)
{
$article['title'] = str_replace('"', '\"', $article['title']);
$article['description'] = str_replace('"', '\"', $article['description']);
$article['url'] = str_replace('"', '\"', $article['url']);
$articles .= $tips . '{"title":"' . $article['title'] . '","description":"' . $article['description'] . '","url":"' . $article['url'] . '"}';
$tips = ',';
}
$articles .= ']';
$post_data = '{"touser":"' . $user_id . '","msgtype":"news","agentid":' . $agentid . ',"news":{"articles":' . $articles . '}}';
return self::doPost($url, $params, $post_data);
}
private static function doGet($url, $params = array())
{
$ch = curl_init($url . '?' . http_build_query($params));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 获取数据返回
curl_setopt($ch, CURLOPT_BINARYTRANSFER, true); // 在启用 CURLOPT_RETURNTRANSFER 时候将获取数据返回
$result = curl_exec($ch);
curl_close($ch);
return json_decode($result, true);
}
private static function doPost($url, $params = array(), $post_data = array())
{
$ch = curl_init($url . '?' . http_build_query($params));
curl_setopt($ch, CURLOPT_HEADER, false);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
$info = curl_exec($ch);
curl_close($ch);
return json_decode($info, true);
}
}
$receiver = "$argv";
$title = "$argv";
$desc = "$argv";
$url = "http://zabbix网址/zabbix";
//$receiver = "接收人";
$content = array(
array(
'title' => $title,
'description' => $desc,
'url' => $url
)
);
$r = SdkQywx::getInstance()->sendNewsMessage(43, $receiver, $content);
----------------------------------------------------------------------------------python
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
#!/usr/bin/python
#coding:utf-8
import smtplib
from email.MIMEText import MIMEText
import sys
import os
import argparse
import logging
import datetime
mail_host = 'mailex.com'
mail_user = 'zabbix@mailex.com'
mail_pass = 'wslmwps'
mail_postfix = 'mailex.com'
mail_nickname = 'zabbix'
######################################
######################################
global sendstatus
global senderr
def send_mail(mail_to,subject,content):
me = mail_nickname +"<"+mail_user+">"
msg = MIMEText(content)
msg['Subject'] = subject
msg['From'] = me
msg['to'] = mail_to
try:
smtp = smtplib.SMTP()
smtp.connect(mail_host)
smtp.login(mail_user,mail_pass)
smtp.sendmail(me,mail_to,msg.as_string())
print 'send ok'
sendstatus = True
except Exception , e:
sendert=str(e)
#print senderr
sendstatus = False
def logwrite(sendstatus,mail_to,content):
logpath='/var/log/zabbix/alert'
if not sendstatus:
content = senderr
if not os.path.isdir(logpath):
os.makedirs(logpath)
t=datetime.datetime.now()
daytime=t.strftime('%Y-%m-%d')
daylogfile=logpath+'/'+str(daytime)+'.log'
logging.basicConfig(filename=daylogfile,level=logging.DEBUG)
logging.info('*'*130)
logging.debug(str(t)+'mail send to{0},content is :\n {1}'.format(mail_to,content))
if__name__=="__main__":
parser = argparse.ArgumentParser(description='Send mail to user for zabbix alterting')
parser.add_argument('mail_to',action="store",help='The address of the E-mail that send to user')
parser.add_argument('subject',action="store",help='The subject of the E-mail')
parser.add_argument('content',action="store",help='The content of the E-mail')
args = parser.parse_args()
mail_to=args.mail_to
subject=args.subject
content=args.content
send_mail(mail_to,subject,content)
#logwrite(sendstatus,mail_to,content)
页:
[1]