### 使用 Python3 调用 Zabbix API 获取当前告警数据 为了通过 Python3 实现调用 Zabbix API 并获取当前告警数据的功能，可以按照以下方式构建代码逻辑。Zabbix 的 API 基于 JSON-RPC 协议，因此可以通过 HTTP 请求发送命令并解析返回的结果。 以下是完整的实现过程： #### 1. 安装依赖库 首先需要安装 `requests` 库来处理 HTTP 请求。如果尚未安装该库，则可通过 pip 进行安装： ```bash pip install requests ``` #### 2. 编写登录函数 在访问任何资源之前，必须先向 Zabbix 发送认证请求以获得会话令牌 (auth token)。 ```python import json import requests def zabbix_login(url, user, password): headers = {'Content-Type': 'application/json-rpc'} payload = { "jsonrpc": "2.0", "method": "user.login", "params": { "user": user, "password": password }, "id": 1 } response = requests.post(url, data=json.dumps(payload), headers=headers).json() if 'result' in response: return response['result'] else: raise Exception(f"Login failed: {response.get('error', '')}") ``` #### 3. 获取当前告警数据 利用已获取的 auth token 来查询触发器状态为 PROBLEM 的事件列表。 ```python def get_current_alerts(url, auth_token): headers = {'Content-Type': 'application/json-rpc'} payload = { "jsonrpc": "2.0", "method": "trigger.get", "params": { "output": ["description", "status", "value"], "filter": {"value": 1}, # 只获取处于问题状态的触发器 "expandDescription": True, "monitored": True, "active": True, "skipDependent": True, "selectHosts": ["host"] }, "auth": auth_token, "id": 2 } response = requests.post(url, data=json.dumps(payload), headers=headers).json() if 'result' in response: return response['result'] else: raise Exception(f"Failed to fetch alerts: {response.get('error', '')}") ``` #### 4. 主程序入口 将以上两个部分组合起来形成最终脚本。 ```python if __name__ == "__main__": url = "http://your-zabbix-server/api_jsonrpc.php" username = "Admin" password = "zabbix" try: # 登录并获取 Auth Token auth_token = zabbix_login(url, username, password) # 查询当前告警数据 alerts = get_current_alerts(url, auth_token) # 打印结果 for alert in alerts: host_name = ", ".join([h["host"] for h in alert["hosts"]]) print(f"{alert['description']} on Host(s): {host_name}") except Exception as e: print(e) ``` 此代码实现了从指定 URL 和凭证中提取当前存在的所有告警信息，并将其打印到控制台[^1]。 --- ###