1、如果接企业微信请参考下面的文章
https://www.txisfine.cn/archives/9c078bb7.html
感谢上述文章的作者提供的思路
ChatGPT 是最近很火的 AI 智能机器人程序,2 个月活跃用户突破 1 亿,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,真正像人类一样来聊天交流,甚至能完成撰写邮件、视频脚本、文案、翻译、代码,写论文等任务。
Zabbix 开源社区推文实测|ChatGPT 对 Zabbix 用户有什么影响?展示了将一些 Zabbix 相关的问题丢给 ChatGPT 处理来提升工作效率。既然都说到这里了,那我们能不能将 Zabbix 告警信息丢给 ChatGPT,在告警的第一时间先给出一份可以参考的建议呢? 所以,基于 Zabbix 能力,我们将告警发给了 ChatGPT,并通过钉钉发送的方式给出告警信息和修复建议。效果如下图:001、准备
- 注册 ChatGPT 账号
- 注册 AirCode 账号
- 准备 Zabbix 钉钉内部应用
因为需要接入 ChatGPT,必须要现有一个 OpenAI 的账号,AirCode 是一个 nodejs 运行时的 Serverless 平台,主要做 OpenAI 的 APIProxy,因为毕竟是国际服务,网络抖动会影响服务质量。
如何注册网络上很多资料,这里不在赘述。
还要准备一个 Zabbix 钉钉内部应用,用来接受告警和建议
002、开始
获取 OpenAI 的 KEY
登录到 OpenAI,访问Account API Keys - OpenAI API,点击 Create new secret key,创建一个新的 key,并保存备用。创建一个 AirCode 项目
登录到 AirCode,创建一个新项目。
给项目命名一下,Runtime 和 Region 默认就好,点击 Create 进入编辑区。
1.创建一个文件,比如 main.js,将bh1xaq/ChatGPT-zabbixAlert中的 openai.js 拷贝进去。2.安装 axios 依赖,在 Dependencies 下面搜axios
,找最新版本安装即可。
3.配置环境变量,我们需要把 OpenAI 的 KEY 配置到环境变量,同时为了您的 API 更安全,我们还需要协商一个 Zabbix 请求我们 APIProxy 的 KEY。
OPENAIKEY - 获取到的 OpenAI 的 KEYZAKEY - Zabbix 请求 APIProxy 的 KEY(需要自定义)
4.发布代码,并获得 APIProxy 地址备用。点击 Deploy,填写 Commit,发布代码。下面红框的位置就是 APIProxy 地址。
配置 Zabbix 通知媒介
1.登录 Zabbix 管理端,选择报警媒介类型
,创建媒体类型
。类型:WebHook
参数:
- Zakey:Zabbix 请求 APIProxy 的 KEY
- Openaiurl: OpenAI APIProxy 地址
- Message:{ALERT.MESSAGE}
- Subject:{ALERT.SUBJECT}
- To:{ALERT.SENDTO}
超时时间:60s
粘贴脚本,将 下面的代码拷贝到 脚本 中。需要修改的部分已经标红
var weworkApp = { // touser: null, // message: null, // proxy: null, // openai_url: null, // Zakey zakey: null, msgtype: 'markdown', // 获取钉钉 AccessToken getAccessToken: function () { var url = 'https://oapi.dingtalk.com/gettoken?appkey=************&appsecret=*******************', request = new CurlHttpRequest(); // 设置代理 if (weworkApp.proxy) { request.setProxy(weworkApp.proxy); } request.AddHeader('Content-Type: application/json'); response = request.Get(url); try { response = JSON.parse(response); return response.access_token; } catch (error) { response = null; } if (request.Status() !== 200 || response.errcode !== 0) { if (typeof response.errmsg === 'string') { throw response.errmsg; } else { throw 'Unknown error. Check debug log for more information.' } } }, // 不用修改 askOpenAI: function (quesion) { // OpenAI Proxy On AirCode var url = weworkApp.openai_url, request = new CurlHttpRequest(), data = { "zakey": weworkApp.zakey, "quesion": quesion }; // 设置代理 if (weworkApp.proxy) { request.setProxy(weworkApp.proxy); } request.AddHeader('Content-Type: application/json'); response = request.Post(url, JSON.stringify(data)); try { response = JSON.parse(response); } catch (error) { response = { message: "" }; } return response.message; }, // 发消息 sendMessage: function (access_token) { var params = { chatid: weworkApp.touser, msgtype: weworkApp.msgtype, markdown: { title: "Zabbix通知", text: weworkApp.message }, enable_duplicate_check: 1, duplicate_check_interval: 20 }, data, response, request = new CurlHttpRequest(), url = 'https://oapi.dingtalk.com/chat/send?access_token=' + access_token; // 设置代理 if (weworkApp.proxy) { request.setProxy(weworkApp.proxy); } request.AddHeader('Content-Type: application/json'); data = JSON.stringify(params); // 在日志中不展示 AccessToken Zabbix.Log(4, '[weworkApp Webhook] URL: ' + url.replace(weworkApp.access_token, '<ACCESS_TOKEN>')); Zabbix.Log(4, '[weworkApp Webhook] params: ' + data); response = request.Post(url, data); Zabbix.Log(4, '[weworkApp Webhook] HTTP code: ' + request.Status()); try { response = JSON.parse(response); } catch (error) { response = null; } if (request.Status() !== 200 || response.errcode !== 0) { if (typeof response.errmsg === 'string') { throw response.errmsg; } else { throw 'Unknown error. Check debug log for more information.' } } }}try { var params = JSON.parse(value); if (params.HTTPProxy) { weworkApp.proxy = params.HTTPProxy; } weworkApp.corpid = params.Corpid; weworkApp.corpsecret = params.Corpsecret; weworkApp.touser = params.To; weworkApp.openai_url = params.Openaiurl; weworkApp.zakey = params.Zakey; var access_token = weworkApp.getAccessToken(); weworkApp.message = params.Subject + 'n' + params.Message; //如果是故障类型的通知,就问一下 OpenAI if (params.Subject.indexOf("故障恢复") == -1) { var aiAnswer = weworkApp.askOpenAI(params.Subject); weworkApp.message = weworkApp.message + 'n --- n OpenAI - 砖家建议 - 众所周知砖家建议仅供参考):n ' + aiAnswer; } // 发钉钉通知 weworkApp.sendMessage(access_token); return '200 OK';}catch (error) { Zabbix.Log(4, '[weworkApp Webhook] notification failed: ' + error); throw 'Sending failed: ' + error + '.';}
2.创建消息模板。
添加故障和故障恢复两个类型的消息。以下供参考。
故障: {EVENT.NAME}定位ID:{EVENT.ID}出现时间:{EVENT.DATE} {EVENT.TIME}所属设备:{HOST.NAME}严重程度:{EVENT.SEVERITY}{TRIGGER.URL}故障恢复:{EVENT.RECOVERY.NAME}定位ID:{EVENT.ID}恢复时间:{EVENT.RECOVERY.DATE} {EVENT.RECOVERY.TIME} 故障时长:{EVENT.DURATION}影响设备:{HOST.NAME}严重程度:{EVENT.SEVERITY}{TRIGGER.URL}
保存即可,我们可以进行一下测试。
3.告警信息定向推送给谁,需要一个 TOUSER 的属性,在这里添加即可。
4.将报警媒介关联到触发器动作中。
zabbix 特别注意:
{ALERT.SUBJECT} 相当于 动作的主题
在zabbix里面把动作的主题配置成 故障: {EVENT.NAME}。这样访问chatapi的时候就能返回想要的信息
特别说明
AI 无法代替人类,提供的建议仅供修复参考,请运维工程师分析合理性后进行执行,以防止扩大故障。
本项目使用的 OpenAI 模型为text-davinci-003。