[p=30,2,center]学习资料：IT运维管理社区专家讲堂直播300期视频回放

[p=30,2,center]

• 微信报警
  
  
  

配置微信企业号

• 在组织架构中，新建二级组，并添加相关人员，注意添加人员的账号要记清楚。后期zabbix发送邮件时需要填写用户名（也可以填写@all发送给所有的人）
• 点击"修改部门",获取ID
• 去设置-->功能设置-->权限管理，最重要的是CorpID,Secret两个密钥，后期脚本里会利用它俩生成一个token，然后利用token去发送消息
  
  
  

[url=][/url]配置zabbix-server

将weixin.py放到/usr/local/zabbix/alertscripts/目录下

$vim/usr/local/zabbix/alertscripts/weixin.py

#!/usr/bin/envpython

#-*-co**:utf-8-*-

importurllib,urllib2,json

importsys

reload(sys)

sys.setdefaultenco**("utf-8")

classWeChat(object):

__token_id=''

#initattribute

def__init__(self,url):

self.__url=url.rstrip('/')

self.__corpid=''#微信企业号-设置-权限管理可查看

self.__secret=''#微信企业号-设置-权限管理可查看

#GetTokenID

defauthID(self):

params={'corpid':self.__corpid,'corpsecret':self.__secret}

data=urllib.urlencode(params)

content=self.getToken(data)

try:

self.__token_id=content['access_token']

#printcontent['access_token']

exceptKeyError:

raiseKeyError

#Establishaconnection

defgetToken(self,data,url_prefix='/'):

url=self.__url+url_prefix+'gettoken?'

try:

response=urllib2.Request(url+data)

exceptKeyError:

raiseKeyError

result=urllib2.urlopen(response)

content=json.loads(result.read())

returncontent

#Getsendmessageurl

defpostData(self,data,url_prefix='/'):

url=self.__url+url_prefix+'message/send?access_token=%s'%self.__token_id

request=urllib2.Request(url,data)

try:

result=urllib2.urlopen(request)

excepturllib2.HTTPErrorase:

ifhasattr(e,'reason'):

print'reason',e.reason

elifhasattr(e,'code'):

print'code',e.code

return0

else:

content=json.loads(result.read())

result.close()

returncontent

#sendmessage

defsendMessage(self,touser,message):

self.authID()

data=json.dumps({

'touser':"@all",

'toparty':"@all",

'totag':"test",

'msgtype':"text",

'agentid':"2",

'text':{

'content':message

},

'safe':"0"

},ensure_ascii=False)

response=self.postData(data)

printresponse

if__name__=='__main__':

a=WeChat('cgi-bin')

a.sendMessage(sys.argv[1],sys.argv[3])

$chmod+x/usr/local/zabbix/alertscripts/weixin.py

$chownzabbix:zabbix/usr/local/zabbix/alertscripts/weixin.py

$pythonzabbixtesttest//$1联系人$2主题$3正文

{u'errcode':0,u'errmsg':u'ok'}

[url=][/url]配置zabbixUI

• 【管理】-【报警媒介类型】-【创建媒介类型】
  
• 【管理】-【用户】-【admin】-【报警媒介】
  
• 【配置】-【动作】-【触发器】-【创建动作】
  

  

  
  

  

  
  
  
  
  
  

• API使用
  
  
  

API采用JSON-RPC实现。这意味着调用任何函数，都需要发送POST请求，输入输出数据都是以JSON格式。大致工作流如下：

• 准备JSON对象，它描述了你想要做什么（创建主机，获取图像，更新监控项等）。
• 采用POST方法向zabbix/api_jsonrpc.php发送此JSON对象，zabbix/是Zabbix前端地址，api_jsonrpc.php是调用API的PHP脚本。可在安装可视化前端的目录下找到。
• 获取JSON格式响应。
• 注：请求除了必须是POST方法之外，HTTPHeaderContent-Type必须为【application/jsonrequest，application/json-rpc，application/json】其中之一。
  
  
  

可以采用脚本或者任何"手动"支持JSONRPC的工具来使用API。而首先需要了解的就是如何验证和如何使用验证ID来获取想要的信息。后面的演示会以Python脚本和基于Curl的例子来呈现API的基本使用。

CLIExample:

$vimzbx_addhost.py

#!/usr/bin/envpython2.7

#co**=utf-8

importjson

importurllib2

importsys

reload(sys)

sys.setdefaultenco**("utf-8")

#basedurlandrequiredheader

url="http://10.0.0.1:8027/api_jsonrpc.php"

header={"Content-Type":"application/json"}

defzbxauth():

#authuserandpassword

data=json.dumps(

{

"jsonrpc":"2.0",

"method":"user.login",

"params":{

"user":"admin",

"password":"123456"

},

"id":0

})

#createrequestobject

request=urllib2.Request(url,data)

forkeyinheader:

request.add_header(key,header[key])

#authandgetauthid

try:

result=urllib2.urlopen(request)

exceptURLErrorase:

print"AuthFailed,PleaseCheckYourNameAndPassword:",e.code

else:

response=json.loads(result.read())

result.close()

#return"AuthSuccessful.TheAuthIDIs:",response['result']

returnresponse['result']

defadd_host(ip):

authid=zbxauth()

#requestjson

data=json.dumps(

{

"jsonrpc":"2.0",

"method":"host.create",

"params":{

"host":ip,

"interfaces":[

{

"type":1,

"main":1,

"useip":1,

"ip":ip,

"dns":"",

"port":"10050"

}

],

"groups":[{"groupid":8}],

"templates":[{"templateid":10108}],

},

"auth":"{0}".format(authid),#theauthidiswhatauthscriptreturns,remeberitisstring

"id":0,

})

#createrequestobject

request=urllib2.Request(url,data)

forkeyinheader:

request.add_header(key,header[key])

#addhost

try:

result=urllib2.urlopen(request)

exceptURLErrorase:

print"Erroras",e

else:

response=json.loads(result.read())

printresponse

result.close()

reutrn"Addhost:{0}isok.".format(ip)

printadd_host('8.8.8.8')

OpsWorlder原创

[p=30,2,center]学习资料：IT运维管理社区专家讲堂直播300期视频回放

[p=30,2,center]

• 微信报警
  
  
  

配置微信企业号

• 在组织架构中，新建二级组，并添加相关人员，注意添加人员的账号要记清楚。后期zabbix发送邮件时需要填写用户名（也可以填写@all发送给所有的人）
• 点击"修改部门",获取ID
• 去设置-->功能设置-->权限管理，最重要的是CorpID,Secret两个密钥，后期脚本里会利用它俩生成一个token，然后利用token去发送消息
  
  
  

[url=][/url]配置zabbix-server

将weixin.py放到/usr/local/zabbix/alertscripts/目录下

$vim/usr/local/zabbix/alertscripts/weixin.py

#!/usr/bin/envpython

#-*-co**:utf-8-*-

importurllib,urllib2,json

importsys

reload(sys)

sys.setdefaultenco**("utf-8")

classWeChat(object):

__token_id=''

#initattribute

def__init__(self,url):

self.__url=url.rstrip('/')

self.__corpid=''#微信企业号-设置-权限管理可查看

self.__secret=''#微信企业号-设置-权限管理可查看

#GetTokenID

defauthID(self):

params={'corpid':self.__corpid,'corpsecret':self.__secret}

data=urllib.urlencode(params)

content=self.getToken(data)

try:

self.__token_id=content['access_token']

#printcontent['access_token']

exceptKeyError:

raiseKeyError

#Establishaconnection

defgetToken(self,data,url_prefix='/'):

url=self.__url+url_prefix+'gettoken?'

try:

response=urllib2.Request(url+data)

exceptKeyError:

raiseKeyError

result=urllib2.urlopen(response)

content=json.loads(result.read())

returncontent

#Getsendmessageurl

defpostData(self,data,url_prefix='/'):

url=self.__url+url_prefix+'message/send?access_token=%s'%self.__token_id

request=urllib2.Request(url,data)

try:

result=urllib2.urlopen(request)

excepturllib2.HTTPErrorase:

ifhasattr(e,'reason'):

print'reason',e.reason

elifhasattr(e,'code'):

print'code',e.code

return0

else:

content=json.loads(result.read())

result.close()

returncontent

#sendmessage

defsendMessage(self,touser,message):

self.authID()

data=json.dumps({

'touser':"@all",

'toparty':"@all",

'totag':"test",

'msgtype':"text",

'agentid':"2",

'text':{

'content':message

},

'safe':"0"

},ensure_ascii=False)

response=self.postData(data)

printresponse

if__name__=='__main__':

a=WeChat('cgi-bin')

a.sendMessage(sys.argv[1],sys.argv[3])

$chmod+x/usr/local/zabbix/alertscripts/weixin.py

$chownzabbix:zabbix/usr/local/zabbix/alertscripts/weixin.py

$pythonzabbixtesttest//$1联系人$2主题$3正文

{u'errcode':0,u'errmsg':u'ok'}

[url=][/url]配置zabbixUI

• 【管理】-【报警媒介类型】-【创建媒介类型】
  
• 【管理】-【用户】-【admin】-【报警媒介】
  
• 【配置】-【动作】-【触发器】-【创建动作】
  

  

  
  

  

  
  
  
  
  
  

• API使用
  
  
  

API采用JSON-RPC实现。这意味着调用任何函数，都需要发送POST请求，输入输出数据都是以JSON格式。大致工作流如下：

• 准备JSON对象，它描述了你想要做什么（创建主机，获取图像，更新监控项等）。
• 采用POST方法向zabbix/api_jsonrpc.php发送此JSON对象，zabbix/是Zabbix前端地址，api_jsonrpc.php是调用API的PHP脚本。可在安装可视化前端的目录下找到。
• 获取JSON格式响应。
• 注：请求除了必须是POST方法之外，HTTPHeaderContent-Type必须为【application/jsonrequest，application/json-rpc，application/json】其中之一。
  
  
  

可以采用脚本或者任何"手动"支持JSONRPC的工具来使用API。而首先需要了解的就是如何验证和如何使用验证ID来获取想要的信息。后面的演示会以Python脚本和基于Curl的例子来呈现API的基本使用。

CLIExample:

$vimzbx_addhost.py

#!/usr/bin/envpython2.7

#co**=utf-8

importjson

importurllib2

importsys

reload(sys)

sys.setdefaultenco**("utf-8")

#basedurlandrequiredheader

url="http://10.0.0.1:8027/api_jsonrpc.php"

header={"Content-Type":"application/json"}

defzbxauth():

#authuserandpassword

data=json.dumps(

{

"jsonrpc":"2.0",

"method":"user.login",

"params":{

"user":"admin",

"password":"123456"

},

"id":0

})

#createrequestobject

request=urllib2.Request(url,data)

forkeyinheader:

request.add_header(key,header[key])

#authandgetauthid

try:

result=urllib2.urlopen(request)

exceptURLErrorase:

print"AuthFailed,PleaseCheckYourNameAndPassword:",e.code

else:

response=json.loads(result.read())

result.close()

#return"AuthSuccessful.TheAuthIDIs:",response['result']

returnresponse['result']

defadd_host(ip):

authid=zbxauth()

#requestjson

data=json.dumps(

{

"jsonrpc":"2.0",

"method":"host.create",

"params":{

"host":ip,

"interfaces":[

{

"type":1,

"main":1,

"useip":1,

"ip":ip,

"dns":"",

"port":"10050"

}

],

"groups":[{"groupid":8}],

"templates":[{"templateid":10108}],

},

"auth":"{0}".format(authid),#theauthidiswhatauthscriptreturns,remeberitisstring

"id":0,

})

#createrequestobject

request=urllib2.Request(url,data)

forkeyinheader:

request.add_header(key,header[key])

#addhost

try:

result=urllib2.urlopen(request)

exceptURLErrorase:

print"Erroras",e

else:

response=json.loads(result.read())

printresponse

result.close()

reutrn"Addhost:{0}isok.".format(ip)

printadd_host('8.8.8.8')

OpsWorlder原创