夜莺自定义告警模板
发布时间：2025-11-05 12:18:13 来源：创站工坊 作者：应用开发
希望在告警通知里有以下数据：
告知当前系统还有多少未处理的夜莺义告告警。告知当前告警恢复时候的自定具体值。告警通知里增加查看未处理告警的警模页面链接。具体实现
要实现上面的夜莺义告需求很简单，夜莺监控的自定数据库表alert_cur_event保存了我们所需要的当前未处理的告警总数，而且夜莺监控也提供了查询未处理告警的警模面板，而对于告警恢复时候的夜莺义告值我们只需要根据自定义的恢复promql即可查询。
最简单的自定方式就是直接通过notify.py脚本进行告警发送，我们只需要做一丢丢修改即可。警模
整体脚本如下：
复制#!/usr/bin/env python # -*- coding: UTF-8 -*- import sys import json import requests import pymysql # 处理字符问题 reload(sys) sys.setdefaultencoding(utf-8) # 通过api查询指标 def getPrometheus(url,夜莺义告 promql): response = requests.get(url, params={query: promql}) data = json.loads(response.text) # 提取指标数据 if response.status_code == 200 result = data[data][result] if len(result) == 1: return result[0][value][1] else: return 0 else: return 0 def count_rows_and_get_rule_names(): try: conn = pymysql.connect( host=127.0.0.1, port=3306, user=n9e, passwd=1234, db=n9e_v6, charset=utf8mb4 ) cursor = conn.cursor() # Count the total number of rows in the table count_query = "SELECT COUNT(*) FROM alert_cur_event" cursor.execute(count_query) total_rows = cursor.fetchone()[0] return total_rows except Exception as e: print("Error: ", e) class Sender(object): @classmethod def send_qywx(cls, payload): users = payload.get(event).get("notify_users_obj") is_recovered = payload.get(event).get("is_recovered") tokens = {} phones = {} res = {} history_row = count_rows_and_get_rule_names() if is_recovered: # 获取自定义的恢复promql promQL = payload.get(event).get("annotations").get("recovery_promql") url = "http://127.0.0.1:9090/api/v1/query" res = getPrometheus(url, promQL) # 查询活跃告警的面板 currAlert = "http://127.0.0.1:17000/alert-cur-events" for u in users: if u.get("phone"): phones[u.get("phone")] = 1 contacts = u.get("contacts") if contacts.get("qywx_robot_token", ""): tokens[contacts.get("qywx_robot_token", "")] = 1 headers = { "Content-Type": "application/json;charset=utf-8", "Host": "qyapi.weixin.qq.com" } for t in tokens: url = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key={}".format(t) content = payload.get(tpls).get("qywx", "qywx not found") content = "# **当前环境的全部告警数**: %s" % (history_row) + "\n" + content if is_recovered: content = content + "\n" + "> **恢复时值**: %s" % (res) if history_row > 0: content = content + "\n" + "[当前活跃告警](%s)" % (currAlert) body = { "msgtype": "markdown", "markdown": { "content": content } } response = requests.post(url, headers=headers, data=json.dumps(body)) def main(): payload = json.load(sys.stdin) with open(".payload", w) as f: f.write(json.dumps(payload, indent=4)) for ch in payload.get(event).get(notify_channels): send_func_name = "send_{}".format(ch.strip()) if not hasattr(Sender, send_func_name): print("function: {} not found", send_func_name) continue send_func = getattr(Sender, send_func_name) send_func(payload) def hello(): print("hello nightingale") if __name__ == "__main__": if len(sys.argv) == 1: main() elif sys.argv[1] == "hello": hello() else: print("I am confused")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.需要在服务器上安装pymysql以及requests包
然后将上面的脚本放到夜莺监控面板->系统设置->通知设置->通知脚本中，并将脚本设置为启用状态。自定
然后新增名叫qywx的警模通知媒介以及名叫qywx_robot_token的联系方式，在发送告警的夜莺义告时候会通过通知媒介来调用通知方法，比如你的自定通知媒介名叫zhangsan，服务器托管那么你定义的警模方法名就是send_zhangsan。另外还会从联系方式处获取发送的token。
然后我们来创建一个通知模板，这个模板是在原生的基础上进行更改的，如下创建一个名叫qywx的模板。
复制> **级别状态**: {{if .IsRecovered}}<font color="info">告警恢复</font>{{else}}<font color="warning">发生告警</font>{{end}} > **级别级别**: S{{.Severity}} > **告警类型**: {{.RuleName}}{{if .RuleNote}} > **告警详情**: {{.RuleNote}}{{end}}{{if .TargetIdent}} > **监控对象**: {{.TargetIdent}}{{end}} > **监控指标**: {{.TagsJSON}}{{if not .IsRecovered}} > **触发时值**: {{.TriggerValue}}{{end}} {{if .IsRecovered}}> **恢复时间**: {{timeformat .LastEvalTime}}{{else}}> **首次触发时间**: {{timeformat .FirstTriggerTime}}{{end}} {{$time_duration := sub now.Unix .FirstTriggerTime}}{{if .IsRecovered}}{{$time_duration = sub .LastEvalTime .FirstTriggerTime}}{{end}}> **距离首次告警**: {{humanizeDurationInterface $time_duration}} > **发送时间**: {{timestamp}}1.2.3.4.5.6.7.8.9.10.在实际发送过程中会对模板进行相应的增加。
最后，再来配置告警，比如我们现在要配置一个K8s中Pod的状态异常的告警规则，如下：
填写具体的规则名以及备注，并且填写具体的promql。
往下继续填写通知媒介以及附加信息。
其中附加信息中就有告警恢复时候的promql，在python脚本中会获取当前的promql，然后调用prometheus的接口进行查询当前值，最后填充到告警模板中去。
以上就是具体的b2b信息网实现思路，希望对你有所启发。
加餐
除了这种python脚本的方式，还可以通过自定义webhook的方式实现，夜莺是支持回调地址的，只需要把回调地址填写进去即可。
那这个webhook应该怎么开发呢？
其实不需要我们做啥大的开发，直接把夜莺的源码里告警相关的CV出来，改吧改吧就能直接用了。
首先，把alert_cur_event的数据结构弄过来，查表就查它。
其次，增加一个查询prometheus的接口，如下：
复制package prometheus import ( "context" "devops-webhook-service/src/server/config" "github.com/prometheus/client_golang/api" "github.com/prometheus/client_golang/api/prometheus/v1" "github.com/prometheus/common/model" "github.com/toolkits/pkg/logger" "time") func GetMetricsValue(promql string) string { client, err := api.NewClient(api.Config{ Address: config.C.Prometheus.Address, }) if err != nil { logger.Error("init prometheus client failed. err: ", err) } queryAPI := v1.NewAPI(client) result, warnings, err := queryAPI.Query(context.TODO(), promql, time.Now()) if err != nil { // handle error logger.Error("query prometheus metrics failed. err: ", err) } if len(warnings) > 0 { // handle warnings } vector := result.(model.Vector) //for _, sample := range vector { // fmt.Printf("Time: %v, Value: %v\n", sample.Timestamp, sample.Value) //} return vector[0].Value.String() }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.再则，我们就可以把需要的告警字段都动议到告警模板中，通过template自动填充数据了。
复制## 当前环境的告警总数: {{ .TotalAlert}} --- **级别状态**: {{if .IsRecovered}}<font color="info">S{{.Severity}} Recovered</font>{{else}}<font color="warning">S{{.Severity}} Triggered</font>{{end}} **规则标题**: {{.RuleName}}{{if .TargetIdent}} **监控对象**: {{.TargetIdent}}{{end}}{{ if .IsRecovered}} **当前值**: {{ .RecoveryValue}}{{end}} **监控指标**: {{.TagsJSON}}{{if not .IsRecovered}} **触发时值**: {{.TriggerValue}}{{end}} {{if .IsRecovered}}**恢复时间**: {{timeformat .LastEvalTime}}{{else}}**首次触发时间**: {{timeformat .TriggerTime}}{{end}} **发送时间**: {{timestamp}} ---1.2.3.4.5.6.7.8.9.10.11.最后，就是在notify.go中做一丢丢的小修改。
比如event事件增加两个字段。免费源码下载
复制type NoticeEvent struct { *models.AlertCurEvent RecoveryValue string // 恢复时候的值 TotalAlert int // 告警总数 }1.2.3.4.5.比如在notify.go中的GenNotice方法里，增加查询prometheus和数据库的代码。
复制var recoveryValue string if event.IsRecovered { text := event.RuleNote promql := strings.Split(text, "=")[1] recoveryValue = prometheus.GetMetricsValue(promql) } // 获取当前剩余的总告警数 events, err := models.AlertCurEventGetAll(event.Cluster) if err != nil { logger.Error("get alert event failed. err: ", err) }1.2.3.4.5.6.7.8.9.10.11.12.整体代码也就只需要一丢丢东西。
最后
以上就是整体的实现了，这只是领导根据领导的需要做的，每个团队的需求不一样，实现方式肯定也不通，这里只是抛砖引玉。
个人建议使用webhook比较好一点，因为可以比较灵活的增加其他的功能，比如告警认领，比如告警抑制，比如告警转发等。
另外，最近刚换工作没多久，写的文章少了，但是对技术的热爱并没有减少。
- 电脑Symn未指定错误的解决方法（解析Symn未指定错误的原因及解决方案）
- C++ 成员函数的重载，继承，覆盖和隐藏
- MD5加密
- AR/VR/MR，Android开发者可以做些什么？
- 在之前的文章中, 我们讨论过如何在Linux服务器安装各种各样的打印机（当然也包括网络扫描仪）。今天我们将来处理另一端：如何通过桌面客户端来访问网络打印机/扫描仪。网络环境 在这个安装教程中，我们的服务器（Debian Wheezy 7.2版本）的IP地址是192.168.0.10，我们的客户端(Ubuntu 12.04版本)的IP地址是192.168.0.105.注意这两台机器是在同一个网段（192.168.0.0/24).假如我们想允许打印机访问其它网段，我们需要在服务器上修改cupsd.conf文件的以下部分： Order allow,deny Allow localhost Allow from XXX.YYY.ZZZ.*（在上述例子中，我们授予打印机从本地或者任何系统能够访问打印机，这些系统的IPv4地址以XXX.YYY.ZZZ开始。为了验证哪些打印机可以在我们的服务器上适用，我们也可以在服务器上使用lpstat命令，或者浏览网页https://192.168.0.10:631/printers page.root@debian:~# lpstat -a EPSON_Stylus_CX3900 accepting requests since Mon 18 Aug 2014 10:49:33 AM WARSTPDF accepting requests since Mon 06 May 2013 04:46:11 PM WARSTSamsungML1640Series accepting requests since Wed 13 Aug 2014 10:13:47 PM WARST在Ubuntu桌面安装网络打印机 在我们的Ubuntu 12.04的客户端，我们将打开Printing菜单(Dash ->Printing).你会注意到在其它发行版中，这个名字也许会有一点差别（例如会叫做Printers 或者 Print & Fax）:还没有打印机添加到我们的客户端：下面是在Ubuntu桌面客户端安装一台网络打印机的一些步骤。1) “Add”按钮将弹出 New Printer 菜单。我们将选择Network printer ->Find Network Printer并输入我们服务器的IP地址，接着点击Find:2) 在最下面我们将会看到可使用的打印机的名称。我们来选择这台三星打印机并按Forward:3) 我们将会被要求填写一些关于我们打印机的信息。当我们输入完成时，将点击 Apply按钮。4) 我们接下来将被询问是否打印一张测试页。让我们点击Print test page吧:这个打印任务将被创建为本地id 2：5)适用我们服务器上的CUPS网络借口，我们可以观察到打印任务已经提交成功了（打印机 ->SamsungML1640系列 ->显示完成任务):我们也可以通过在打印机服务器上运行以下命令显示同样信息： root@debian:~# cat /var/log/cups/page_log | grep -i samsung SamsungML1640Series root 27 [13/Aug/2014:22:15:34 -0300] 1 1 - localhost Test Page - -SamsungML1640Series gacanepa 28 [18/Aug/2014:11:28:50 -0300] 1 1 - 192.168.0.105 Test Page - -SamsungML1640Series gacanepa 29 [18/Aug/2014:11:45:57 -0300] 1 1 - 192.168.0.105 Test Page - -这个page_log日志显示每一页被打印过的信息，只包括哪些用户发送这些打印任务，打印日期&时间，以及客户端的IPv4地址。要安装Epson喷墨和PDF打印机，我们只需重复第1-5的步骤即可，并每一次选择左边的打印队列。例如，在下图中选择PDF打印机：然而，请注意到根据CUPS-PDF 文档中，根据默认：PDF文件将会被放置在打印作业的所有者命名的子目录内。在这个案例中，打印作业的所有者不能被识别（i.e.不会存在服务器中）输出的内容被放置在匿名操作的文件中。这些默认的文件夹可以通过改变在/etc/cups/cups-pdf目录中的Out值和AnonDirName变量来修改。这里，${HOME}被扩展到用户的家目录中：Out ${HOME}/PDFAnonDirName /var/spool/cups-pdf/ANONYMOUS网络打印实例 实例 #1 从Ubuntu12.04中打印，通常在本地用gacanepa（具有相同名字存在打印机服务器上）。打印到PDF打印机之后，让我们来检查打印机服务器上的/home/gacanepa/PDF目录下的内容：root@debian:~# ls -l /home/gacanepa/PDF total 368-rw------- 1 gacanepa gacanepa 279176 Aug 18 13:49 Test_Page.pdf-rw------- 1 gacanepa gacanepa 7994 Aug 18 13:50 Untitled1.pdf-rw------- 1 gacanepa gacanepa 74911 Aug 18 14:36 Welcome_to_Conference_-_Thomas_S__Monson.pdf这个PDF文件被创建时的，权限已经设置为600(-rw-------)，这意味着只有打印任务的所有者(在这个例子中是gacanepa )可以访问它们。我们可以通过修改the /etc/cups/cups-pdf.conf文件UserUMask变量的值来改变这种行为。例如，0033的umask值将可以使PDF打印者以及其它所有者拥有创建文件的权限，但是只读权限也会赋予给其它所有者。 root@debian:~# grep -i UserUMask /etc/cups/cups-pdf.conf ### Key: UserUMaskUserUMask 0033对于那些不熟悉umask（有名用户文件创建模式掩码），它作为一组可以用于控制那些为新文件创建时修改默认权限。给予特定的umask值，在计算最终文件的许可权限时，在文件基本权限(0666)和umask的单项按位补码之间进行按位布尔 AND 运算。因此，假如设置一个umask值为0033，那么新文件默认的权限将不是（0033）AND 0666 = 644的值（文件拥有者具有读/写/执行的权限，其他人拥有只读权限）。实例 #2 在Ubuntu12.04执行打印，本地登录用户为jdoe（同样的帐号名称但是服务器上是不存在的）。 root@debian:~# ls -l /var/spool/cups-pdf/ANONYMOUS total 5428-rw-rw-rw- 1 nobody nogroup 5543070 Aug 18 15:57 Linux_-_Wikipedia__the_free_encyclopedia.pdf这个PDF被创建时赋予的权限是666(-rw-rw-rw-)，这意味着每个人都可以访问它们。我们可以通过编辑在/etc/cups/cups-pdf.conf文件中的AnonUMask值来改变这种行为。在这一点上，你也许会疑惑：为什么同样安装一台网络打印机，大多数（当然不是全部）当前的Linux桌面发行版都会内置一个打印到文件的功能来允许用户动态创建PDF文件？使用一台网络PDF打印机有以下好处：一个网络打印机（任何类型的）允许你直接从命令行直接打印，无需首先打开文件。在其它操作系统上安装一个网络客户端，一个PDF网络打印机备件，于是系统管理员不必再单独需要安装PDF创建者实用程序（也避免了最终用户安装这些工具存在的风险）。网络PDF打印机允许通过配置权限直接打印一个网络共享，如我们所见的例子。在Ubuntu桌面安装一个网络扫描仪 这里是通过Ubuntu桌面客户端安装和访问一台网络扫描仪的一些步骤。假设网络扫描仪服务器已经启动并运行所述here.1)让我们第一步来检查在我们的Ubuntu客户端主机上是否存在一台可用的扫描仪。没有先前的安装，你将会看到信息提示没有识别到扫描仪. $ scanimage -L2) 现在我们需要启用saned进程，用来预装Ubuntu桌面。要启用它，我们需要编辑/etc/default/saned文件，并设置RUN变量为yes：$ sudo vim /etc/default/saned # Set to yes to start sanedRUN=yes3) 让我们编辑/etc/sane.d/net.conf文件，并在扫描仪安装后添加服务器IP地址：4) 重启saned进程：$ sudo service saned restart 5) 现在让我们来看看扫描仪是否可用： 现在我们可以打开Simple Scan（或者其它扫描工具）并开始扫描文件。我们可以旋转，修剪，和保存生成的图片：总结 拥有一或多台网络打印机或扫描仪在任何办公和家庭网络中都是非常方便适用的，并同时提供了许多好处。例举如下：多用户（从不同的平台/地方）都能够向打印机发送打印作业的队列。由于硬件共享达到了节约成本和维护的作用。我希望该文可以帮助你更充分地利用这些有点。
- VR直播的挑战和关键技术
- 那些容易被忽视的JavaScript细节总结
- 微软发布万能翻译器 翻译者要下岗？
- 利用系统自带的网络功能创建热点5、进入Wi-Fi安全选项卡，选择 WPA & WPA2 Personal 并且输入密码。7、 进入IPv6选项卡，在Method(方法)里设置为忽略ignore (只有在你不使用IPv6的情况下这么做) 8、 点击 Save(保存) 按钮以保存配置。a、 把 mode=infrastructure 改成 mode=ap 并且保存文件。11、你现在可以把你的设备连上Wifi了。已经过 Android 5.0的小米4测试。(下载了1GB的文件以测试速度与稳定性)1：安装热点产生工具，hostapd复制代码代码如下:interface=wlan0driver=nl80211ssid=XXXXXX #xxxx是你用手机访问时，看到的无线网络的名字hw_mode=gchannel=10macaddr_acl=0auth_algs=3wpa=2wpa_passphrase=XXXXXX #xxxx是你用手机访问时，需要输入的密码。自己设置一个密码wpa_key_mgmt=WPA-PSKwpa_pairwise=TKIPCCMPrsn_pairwise=TKIPCCMP复制代码代码如下:sudo nano /etc/dhcp/dhcpd.conf在文件的最后添加如下：5：最后一步，写一个脚本，放在你的home目录（或者你认为方便的位置），方便的开启热点复制代码代码如下:#!/bin/bashap.sh脚本做好保存后，修改成为可执行的权限 ：复制代码代码如下:sudo ./ap.sh
- JavaScript单线程 & setTimeout定时器
香港云服务器IT资讯网IT技术网源码下载亿华云源码库企商汇服务器租用益华科技益强编程舍亿华互联码力社全栈开发智能时代科技前瞻益华IT技术论坛益强智未来极客码头亿华科技益强前沿资讯多维IT资讯益强编程堂益强智囊团技术快报益强资讯优选益强科技益强数据堂思维库运维纵横编程之道极客编程云智核云站无忧益强科技亿华智慧云亿华智造亿华灵动汇智坊益强IT技术网码上建站益华科技益华科技创站工坊亿华云IT资讯网
- Copyright © 2025 Powered by 夜莺自定义告警模板,创站工坊 滇ICP备2023006006号-44sitemap