【Z投稿】Zabbix监控全国天气实况

Zabbix

发布于 2021-02-03 14:52:27

4680

发布于 2021-02-03 14:52:27

文章被收录于专栏：Zabbix中国官方Zabbix中国官方

作者简介

Wanger，Zabbix运维工程师，熟悉Zabbix开源监控系统的架构，乐于分享Zabbix运维经验，个人公众号“运维开发故事”

擅长领域：Zabbix基础设施运维以及Zabbix图形化展示

本文主要通过一些监控示例来简单介绍zabbix的http agent类型的监控以及map图的简单用法，我们可以通过一些网站查询天气的api来获取天气情况，大部分的地图软件也都支持天气查询，这里我简单介绍几个，有高德地图，百度地图，心知天气，YY天气，个人用的是YY天气，因为我的需求不高，他能轻易地满足我。

点击查看YY天气api地址

创建HTTP agent类型的监控项

以创建北京天气的监控项为例

我们只要把请求的URL和键值填上就可以了

获取数据如下

我们可以根据获取的数据对json进行预处理

创建包含预处理的可依赖监控项

以监控天气信息为例

键值定义尽量规范，依赖项选择刚刚新建的http agent监控项

添加预处理步骤

根据刚才获取到的数据来获取tq的值

除此之外还需要定义气温、风力、风向、相对湿度，添加方法与上面相同

添加高温的触发器

编写脚本批量添加监控项和触发器

但是这样做要添加的监控项和触发器太多了，而且都是重复性的工作，这里我写了个脚本，来对各地城市的监控项和触发器进行批量添加，批量添加的好处是省时省力，而且减少出错概率。

实现思路是获取主机的接口id，并对城市进行循环添加监控项和触发器

‍

#coding=utf-8
import requests,json
ApiUrl = 'http://192.168.99.200/api_jsonrpc.php'
header = {"Content-Type":"application/json"}
user="Admin"
password="zabbix"
city=[{"beijing":"CH010100"},{"shanghai":"CH020100"},{"tianjin":"CH030100"},{"chongqing":"CH040100"},{"harebin":"CH050101"},{"changchun":"CH060101"},{"shenyang":"CH070101"},{"huhehaote":"CH080101"},{"shijiazhuang":"CH090101"},{"taiyuan":"CH100101"},{"xian":"CH110101"},{"jinan":"CH120101"},{"wulumuqi":"CH130101"},{"lasa":"CH140101"},{"xining":"CH150101"},{"lanzhou":"CH160101"},{"yinchuan":"CH170101"},{"zhengzhou":"CH180101"},{"nanjing":"CH190101"},{"wuhan":"CH200101"},{"hangzhou":"CH210101"},{"hefei":"CH220101"},{"fuzhou":"CH230101"},{"nanchang":"CH240101"},{"changsha":"CH250101"},{"guiyang":"CH260101"},{"chengdu":"CH270101"},{"guangzhou":"CH280101"},{"kunming":"CH290101"},{"nanning":"CH300101"},{"haikou":"CH310101"},{"hongkong":"CH320101"},{"aomen":"CH330101"},{"taibei":"CH340101"}]
def get_interface(auth):
    data ={
            "jsonrpc": "2.0",
            "method": "hostinterface.get",
            "params": {
                "output": "extend",
                "hostids": "10343"
             
            },
            "auth": auth,  
            "id": 1
        }
    gethost=requests.post(url=ApiUrl,headers=header,json=data)
    return json.loads(gethost.content)["result"][0]["interfaceid"]
def gettoken():
    data = {"jsonrpc": "2.0",
                "method": "user.login",
                "params": {
                    "user": user,
                    "password": password
                },
                "id": 1,
                "auth": None
            }
    auth=requests.post(url=ApiUrl,headers=header,json=data)
    return json.loads(auth.content)["result"]
#s=requests.get(url="http://api.yytianqi.com/citylist/id/1")
def createhttpitem(auth,interface):
    for dic in city:
        for key,value in dic.items():
            data={
            "jsonrpc": "2.0",
            "method": "item.create",
            "params": {
                "url":"http://api.yytianqi.com/observe",
                "query_fields": [
                    {
                        "city":"%s" %value
                    },
                    {
                        "key": "iopesm5a0uhq3fag"
                    }
                ],
                "interfaceid": "%s" %interface,
                "type":"19",
                "hostid":"10343",
                "delay":"5m",
                "key_":"%s" %key,
                "name":"%s" %key,
                "value_type":"1",
                "output_format":"0",
                "timeout":"3s"
                
            },
            "auth": auth,
            "id": 1
            }
            httpagent=requests.post(url=ApiUrl,headers=header,json=data)
            httpagent=json.loads(httpagent.content)['result']['itemids'][0]
            print(httpagent)
            data={
                "jsonrpc": "2.0",
                "method": "item.create",
                "params": {
                "hostid": "10343",
                "name": "%s-tq" %key,
                "key_": "%s-tq" %key,
                "type": "18",
                "master_itemid": httpagent,
                "value_type": "1",
                "preprocessing": [
                    {
                        "type": "12",
                        "params": "$.data.tq",
                        "error_handler": "1",
                        "error_handler_params": ""
                    }
                ]
                },
                "auth": auth,
                "id": 1
            }
            dependqw=requests.post(url=ApiUrl,headers=header,json=data)
            print(dependqw.content)
            data={
                "jsonrpc": "2.0",
                "method": "item.create",
                "params": {
                "hostid": "10343",
                "name": "%s-fl" %key,
                "key_": "%s-fl" %key,
                "type": "18",
                "master_itemid": httpagent,
                "value_type": "1",
                "preprocessing": [
                    {
                        "type": "12",
                        "params": "$.data.fl",
                        "error_handler": "1",
                        "error_handler_params": ""
                    }
                ]
                },
                "auth": auth,
                "id": 1
            }
            dependfl=requests.post(url=ApiUrl,headers=header,json=data)
            data={
                "jsonrpc": "2.0",
                "method": "item.create",
                "params": {
                "hostid": "10343",
                "name": "%s-qw" %key,
                "key_": "%s-qw" %key,
                "type": "18",
                "master_itemid": httpagent,
                "value_type": "3",
                "preprocessing": [
                    {
                        "type": "12",
                        "params": "$.data.qw",
                        "error_handler": "1",
                        "error_handler_params": ""
                    }
                ]
                },
                "auth": auth,
                "id": 1
            }
            dependqw=requests.post(url=ApiUrl,headers=header,json=data)
            data={
                "jsonrpc": "2.0",
                "method": "item.create",
                "params": {
                "hostid": "10343",
                "name": "%s-fx" %key,
                "key_": "%s-fx" %key,
                "type": "18",
                "master_itemid": httpagent,
                "value_type": "1",
                "preprocessing": [
                    {
                        "type": "12",
                        "params": "$.data.fx",
                        "error_handler": "1",
                        "error_handler_params": ""
                    }
                ]
                },
                "auth": auth,
                "id": 1
            }
            dependfx=requests.post(url=ApiUrl,headers=header,json=data)
            data={
                "jsonrpc": "2.0",
                "method": "item.create",
                "params": {
                "hostid": "10343",
                "name": "%s-sd" %key,
                "key_": "%s-sd" %key,
                "type": "18",
                "master_itemid": httpagent,
                "value_type": "0",
                "preprocessing": [
                    {
                        "type": "12",
                        "params": "$.data.sd",
                        "error_handler": "1",
                        "error_handler_params": ""
                    }
                ]
                },
                "auth": auth,
                "id": 1
            }
            dependsd=requests.post(url=ApiUrl,headers=header,json=data)
            data={
            "jsonrpc": "2.0",
            "method": "trigger.create",
            "params": [
                {
                    "description": "%s温度有点高" %key,
                    "expression": "{tianqi:%s-qw.last()}>30" %key,
                    "opdata": "当前气温:{ITEM.LASTVALUE}",
                    "priority": 3,
                    "manual_close": 1
                }
            ],
            "auth": auth,
            "id": 1
            }
            triggercreate=requests.post(url=ApiUrl,headers=header,json=data)
    return json.loads(dependqw.content)#["result"]
auth=gettoken()
interface=get_interface(auth)
createhttpitem(auth,interface)

实现效果如下