alertmanager 直接配置 飞书 的 webhook ,发现并不满足飞书接口的 json 格式。报错如下

level=error ts=2025-08-28T04:57:02.734Z caller=dispatch.go:310 component=dispatcher msg="Notify for alerts failed" num_alerts=23 err="prometheusalert-webhook/webhook[0]: notify retry canceled due to unrecoverable error after 1 attempts: unexpected status code 400: https://open.feishu.cn/open-apis/bot/v2/hook/xxxxxxx"

上网查询发现开源项目 prometheusalert 按照官方文档配置配置飞书地址,v4.9.1 版本默认的模板和网上找到的模板 空卡片的情况,如下

然后就打算自己写个 python 查询,接收 alertmanager 的消息体,做修改转发给 飞书。

cm.yaml

apiVersion: v1
kind: ConfigMap
metadata:name: alert-flask-cmnamespace: monitor
data:app.py: |from flask import Flask, request, jsonifyimport jsonimport requestsimport loggingfrom datetime import datetimeapp = Flask(__name__)# 飞书机器人 Webhook 地址webhook_url = "https://open.feishu.cn/open-apis/bot/v2/hook/xxxxxxxx"# 日志配置logging.basicConfig(level=logging.INFO)def format_time(timestr):"""把 2025-08-08T06:55:43.825666166Z → 2025-08-08 06:55:43"""try:dt = datetime.fromisoformat(timestr.replace("Z", "+00:00"))return dt.strftime("%Y-%m-%d %H:%M:%S")except Exception:return timestr@app.route('/alert', methods=['POST'])def receive_alert():try:alert_response = request.jsonlogging.info("收到 Alertmanager 消息体: %s", json.dumps(alert_response, ensure_ascii=False))alerts = alert_response.get("alerts", [])if not alerts:logging.info("没有告警")return "no alerts", 200send_status = []for alert in alerts:status = alert.get("status", "firing")if status == "firing":msg_json = format_alert_to_feishu(alert)elif status == "resolved":msg_json = format_resolved_to_feishu(alert)else:logging.info("未知状态: %s", status)continuelogging.info("生成飞书消息体: %s", msg_json)response = send_alert(msg_json)if response is None:send_status.append("发送失败")else:send_status.append(f"发送成功:{response.status_code}")return "; ".join(send_status), 200except Exception as e:logging.exception("处理告警异常")return f"error: {str(e)}", 500def send_alert(json_data):try:response = requests.post(webhook_url, json=json.loads(json_data), timeout=5)response.raise_for_status()logging.info("发送飞书成功,状态码: %s", response.status_code)return responseexcept requests.exceptions.RequestException as e:logging.error("发送飞书失败: %s", e)return Nonedef format_alert_to_feishu(alert):labels = alert.get("labels", {})annotations = alert.get("annotations", {})alert_name = labels.get("alertname", "Unknown")instance = labels.get("instance", "Unknown")severity = labels.get("severity", "N/A")summary = annotations.get("summary", "")description = annotations.get("description", "无描述")start_time = format_time(alert.get("startsAt", "Unknown"))lines = [f"**告警名称**:{alert_name}",f"**告警实例**:{instance}",f"**告警级别**:{severity}",]if summary:lines.append(f"**告警摘要**:{summary}")lines.append(f"**告警描述**:{description}")lines.append(f"**触发时间**:{start_time}")content = "\n".join(lines)webhook_msg = {"msg_type": "interactive","card": {"header": {"title": {"tag": "plain_text", "content": "===== == 告警 == ====="},"template": "red"},"elements": [{"tag": "div", "text": {"tag": "lark_md", "content": content}}]}}return json.dumps(webhook_msg, ensure_ascii=False)def format_resolved_to_feishu(alert):labels = alert.get("labels", {})annotations = alert.get("annotations", {})alert_name = labels.get("alertname", "Unknown")instance = labels.get("instance", "Unknown")summary = annotations.get("summary", "")success_msg = annotations.get("success", "告警已恢复")description = annotations.get("description", "无描述")end_time = format_time(alert.get("endsAt", "Unknown"))lines = [f"**告警名称**:{alert_name}",f"**告警实例**:{instance}",]if summary:lines.append(f"**告警摘要**:{summary}")lines.append(f"**告警描述**:{description}")lines.append(f"**恢复说明**:{success_msg}")lines.append(f"**恢复时间**:{end_time}")content = "\n".join(lines)webhook_msg = {"msg_type": "interactive","card": {"header": {"title": {"tag": "plain_text", "content": "===== == 恢复 == ====="},"template": "green"},"elements": [{"tag": "div", "text": {"tag": "lark_md", "content": content}}]}}return json.dumps(webhook_msg, ensure_ascii=False)if __name__ == '__main__':app.run(host='0.0.0.0', port=4000)

deployment 中的镜像需要自己构建,随便找个 python 镜像作为 base pip 安装 flask、requetsts 即可

deploy-svc.yaml

apiVersion: apps/v1
kind: Deployment
metadata:name: alert-flasknamespace: monitor
spec:replicas: 1selector:matchLabels:app: alert-flasktemplate:metadata:labels:app: alert-flaskspec:containers:- name: alert-flaskimage: python:3.11-slim-bookworm-flaskcommand: ["python", "/app/app.py"]ports:- containerPort: 4000volumeMounts:- name: app-cmmountPath: /appvolumes:- name: app-cmconfigMap:name: alert-flask-cm
---
apiVersion: v1
kind: Service
metadata:name: alert-flask-svcnamespace: monitor
spec:selector:app: alert-flaskports:- name: httpport: 4000targetPort: 4000type: ClusterIP

上面的 configmap、deploy、service 部署好后,更改 alertmanager 的配置

receivers:
- name: feishuwebhook_configs:- send_resolved: trueurl: http://alert-flask-svc:4000/alert

然后飞书就能收到告警了

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/diannao/97185.shtml
繁体地址,请注明出处:http://hk.pswp.cn/diannao/97185.shtml
英文地址,请注明出处:http://en.pswp.cn/diannao/97185.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

『专利好药用力心脑血管健康』——爱上古中医(28)(健康生活是coder抒写优质代码的前提条件——《黄帝内经》伴读学习纪要)

心脏血管三通康,古时丸药精益装。 笔记模板由python脚本于2025-08-26 18:25:03创建,本篇笔记适合喜欢日常保健养生知识的coder翻阅。 学习的细节是欢悦的历程 博客的核心价值:在于输出思考与经验,而不仅仅是知识的简单复述。 Pyth…

在 .NET 8.0 中实现 JWT 刷新令牌

介绍在 Web 开发领域,安全是重中之重。JSON Web Tokens (JWT) 已成为在各方之间安全传输信息的热门选择。然而,在 JWT 过期后,如何维护用户会话并避免频繁登录至关重要。这正是 JWT 刷新令牌应运而生的地方。在本文中,我们将指导您…

深入解析 git push 命令

1. 基础语法 git push 的基本语法如下: git push <远程仓库名> <本地分支名>:<远程分支名> [选项]<远程仓库名>: 通常是 origin(默认的远程仓库名称)。 <本地分支名>:<远程分支名>: 指定要推送的本地分支以及目标远程分支。如果省略远…

UI弹出动画

简介的UI弹出动画 使用方式很简单 挂载到需要弹出的目标 即可 using UnityEngine; using DG.Tweening; using Unity.VisualScripting;/// <summary>/// 简洁的UI动画脚本/// 直接挂载到UI组件上&#xff0c;调用Play()播放缩放弹出动画/// </summary>public class …

PostgreSQL诊断系列(6/6):配置项全景解析——打造你的专属优化清单

&#x1f517; 作为《PostgreSQL诊断系列》的收官之作&#xff0c;今天我们系统梳理 postgresql.conf 中的核心参数&#xff0c;将前5篇的“诊断”转化为“调优”&#xff0c;打造一套生产环境专属的配置模板。 你是否&#xff1a; 不知道哪些参数该调&#xff1f;害怕调错导致…

Flink Slot 不足导致任务Pending修复方案

当前有3个虚拟机节点&#xff0c;每个节点配置的slot节点数量是4&#xff0c;${FLINK_HOME}/conf/flink-conf.yaml 关于slot的配置如下&#xff1a; # The number of task slots that each TaskManager offers. Each slot runs one parallel pipeline. taskmanager.numberOfTas…

亚马逊合规风控升级:详情页排查与多账号运营安全构建

2025年亚马逊掀起的大规模扫号行动&#xff0c;聚焦商品详情页合规性审查&#xff0c;标志着跨境电商合规监管进入严风控时代&#xff0c;此次行动以关键词规范与定价诚信为核心&#xff0c;大量卖家因内容违规遭遇账号停用&#xff0c;对于卖家而言&#xff0c;构建系统化的合…

FISCO-BCOS-Python 模板

基于Python-SDK的FISCO BCOS区块链HelloWorld模板&#xff0c;提供了简单的问候语设置和查询功能。本项目采用现代Python开发实践&#xff0c;包含完整的配置管理、测试框架和项目结构。 快速开始 仓库地址&#xff1a;git clone https://gitee.com/atanycosts/python-fisco-te…

移动端(微信等)使用 vConsole调试console

本文介绍了一种在移动端真机上进行调试的方法——使用VConsole。通过简单的安装步骤和代码配置&#xff0c;开发者可以在移动端直接查看console.log输出&#xff0c;极大提升了调试效率。 摘要生成于 C知道 &#xff0c;由 DeepSeek-R1 满血版支持&#xff0c; 前往体验 >作…

云计算资源分配问题

这里写目录标题一、云计算资源的基本类型二、资源分配的目标三、资源分配的方式四、资源分配的技术与工具五、挑战与优化方向六、实际应用场景举例总结云计算资源分配是指在云计算环境中&#xff0c;根据用户需求、应用程序性能要求以及系统整体效率&#xff0c;将计算、存储、…

深度学习之第二课PyTorch与CUDA的安装

目录 简介 一、PyTorch 与 CUDA 的核心作用 1.PyTorch 2.CUDA 二、CUDA的安装 1.查看 2.下载安装 3.检查是否安装成功 三、PyTorch的安装 1.GPU版本安装 2.CPU版本安装 简介 在深度学习的实践旅程中&#xff0c;搭建稳定且高效的开发环境是一切实验与项目的基础&…

Ubuntu22.04 安装和使用标注工具labelImg

文章目录一、LabelImg 的安装及配置1. 安装2. 配置二、使用1. 基础操作介绍2. 创建自定义标签2.1 修改 predefined_classes.txt2.2 直接软件界面新增3. 图像标注3.1 重命名排序3.2 标注3.2 voc2yolo 格式转换3.3 视频转图片Yolo系列 —— Ubuntu 安装和使用标注工具 labelImgYo…

Jenkins与Docker搭建CI/CD流水线实战指南 (自动化测试与部署)

更多云服务器知识&#xff0c;尽在hostol.com你是否已经厌倦了那个“人肉”部署的重复循环&#xff1f;每一次 git push 之后&#xff0c;都像是一个庄严的仪式&#xff0c;你必须虔诚地打开SSH&#xff0c;小心翼翼地敲下一连串的 git pull, npm install, docker build, docke…

【数据可视化-100】使用 Pyecharts 绘制人口迁徙图:步骤与数据组织形式

&#x1f9d1; 博主简介&#xff1a;曾任某智慧城市类企业算法总监&#xff0c;目前在美国市场的物流公司从事高级算法工程师一职&#xff0c;深耕人工智能领域&#xff0c;精通python数据挖掘、可视化、机器学习等&#xff0c;发表过AI相关的专利并多次在AI类比赛中获奖。CSDN…

5G相对于4G网络的优化对比

5G网络作为新一代移动通信技术&#xff0c;相比4G实现了全方位的性能提升和架构优化。5G通过高速率、低时延和大连接三大核心特性&#xff0c;有效解决了4G网络面临的数据流量爆炸式增长和物联网应用瓶颈问题 &#xff0c;同时引入了动态频谱共享、网络切片等创新技术&#xff…

AR智能巡检:智慧工地的高效安全新引擎

在建筑行业,工地安全管理与施工效率的提升一直是核心议题。随着增强现实(AR)技术的快速发展,AR智能巡检系统正逐步成为智慧工地的“标配”,通过虚实结合、实时交互和智能分析,推动建筑行业迈入数字化、智能化的新阶段。本文将从技术原理、应用场景、核心优势及未来趋势等…

TypeScript:枚举类型

1. 什么是枚举类型&#xff1f;枚举&#xff08;Enum&#xff09;是TypeScript中一种特殊的数据类型&#xff0c;用于定义一组命名的常量值。它允许开发者用一个友好的名称来代表数值或字符串&#xff0c;避免使用“魔法数字”或硬编码值。基本语法&#xff1a;enum Direction …

Maven 编译打包一个比较有趣的问题

前言最近做项目&#xff0c;发现一个比较有意思的问题&#xff0c;其实发现了问题的根源还是很好理解&#xff0c;但是如果突然看到会非常的难以理解。在Java项目中&#xff0c;明明包名错误了&#xff0c;居然可以正常编译打包&#xff0c;IDEA报错了&#xff0c;但是mvn命令正…

Leetcode贪心算法

题目&#xff1a;划分字母区间 题号&#xff1a;763class Solution {public List<Integer> partitionLabels(String s) {List<Integer> list new LinkedList();int[] edge new int[27];char[] chars s.toCharArray();for(int i 0; i <chars.length;i){edge…

【密码学基础】加密消息语法 CMS:给数字信息装个 “安全保险箱”

如果说数字世界是一座繁忙的城市&#xff0c;那么我们每天发送的邮件、合同、软件安装包就是穿梭在城市里的 “包裹”。有些包裹里装着隐私&#xff08;比如银行账单&#xff09;&#xff0c;有些装着重要承诺&#xff08;比如电子合同&#xff09;&#xff0c;还有些关系到设备…