首页 文章 精选 留言 我的

精选列表

搜索[CI/CD集成],共10000篇文章
优秀的个人博客,低调大师

【GitOps·Flux篇】通知与告警:Webhook 集成与事件通知

## 前言 GitOps 是自动化的,但出了问题你需要知道。Flux 的 notification-controller 可以在同步成功、失败、漂移等事件发生时自动发送通知到 Slack/钉钉/企微/邮件等渠道。本篇完整配置通知系统。 --- ## 一、通知架构 ``` Flux 事件流: Source/Sync 事件 → notification-controller → Provider → 通知渠道 (事件过滤器) (通知发送) ↓ Slack / 钉钉 / 企微 Teams / Discord Generic Webhook Rocket.Chat / Email ``` ### 三个 CRD | CRD | 作用 | |-----|------| | Provider | 定义通知渠道(如 Slack Webhook URL) | | Alert | 定义告警规则(什么事件发给谁) | | Receiver | 接收外部 Webhook 触发 Flux 操作 | --- ## 二、配置 Slack 通知 ### 创建 Provider ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Provider metadata: name: slack namespace: flux-system spec: type: slack channel: deployments # Slack 频道名 secretRef: name: slack-webhook-url # 引用 Webhook URL Secret username: Flux Bot # 显示名称 ``` ```bash # 创建 Slack Webhook Secret kubectl create secret generic slack-webhook-url \ --namespace=flux-system \ --from-literal=address=https://hooks.slack.com/services/xxx/yyy/zzz ``` ### 创建 Alert ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Alert metadata: name: deploy-alerts namespace: flux-system spec: providerRef: name: slack # 引用上面的 Provider # 事件源 eventSources: # 监控所有 GitRepository 事件 - kind: GitRepository name: "*" # 监控所有 Kustomization 事件 - kind: Kustomization name: "*" # 监控所有 HelmRelease 事件 - kind: HelmRelease name: "*" # 过滤严重级别 summary: "Flux deployment notifications" # 事件严重级别过滤 eventSeverity: - error # 只通知错误事件 - info # 也通知信息事件(成功同步) ``` ### Slack 消息格式 ``` Flux Bot [4:30 PM] ℹ️ Kustomization/myapp-prod Applied revision main/abc123 Message: Reconciliation finished ``` --- ## 三、配置钉钉通知 ### 钉钉 Provider ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Provider metadata: name: dingtalk namespace: flux-system spec: type: dingtalk secretRef: name: dingtalk-webhook # 钉钉不支持自定义 username ``` ```bash # 创建钉钉 Webhook Secret kubectl create secret generic dingtalk-webhook \ --namespace=flux-system \ --from-literal=address=https://oapi.dingtalk.com/robot/send?access_token=xxx ``` ### 钉钉 Alert ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Alert metadata: name: dingtalk-alerts namespace: flux-system spec: providerRef: name: dingtalk eventSources: - kind: Kustomization name: "*" namespace: flux-system - kind: HelmRelease name: "*" namespace: flux-system eventSeverity: - error - info ``` --- ## 四、配置企业微信通知 ### 企微 Provider ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Provider metadata: name: wecom namespace: flux-system spec: type: wecom secretRef: name: wecom-webhook ``` ```bash kubectl create secret generic wecom-webhook \ --namespace=flux-system \ --from-literal=address=https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxx ``` ### 企微 Alert ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Alert metadata: name: wecom-alerts namespace: flux-system spec: providerRef: name: wecom eventSources: - kind: Kustomization name: "*" - kind: GitRepository name: "*" eventSeverity: - error # 只通知错误 ``` --- ## 五、通用 Webhook 通知 ### 自定义 Provider ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Provider metadata: name: custom-webhook namespace: flux-system spec: type: generic address: https://my-notifier.com/api/flux-events secretRef: name: webhook-auth # 自定义 Headers headers: Authorization: "Bearer token" Content-Type: "application/json" ``` ```bash kubectl create secret generic webhook-auth \ --namespace=flux-system \ --from-literal=token=my-secret-token ``` ### 自定义消息模板 ```yaml apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Provider metadata: name: custom-webhook namespace: flux-system spec: type: generic address: https://my-notifier.com/api/flux-events secretRef: name: webhook-auth # 自定义模板 template: # 自定义请求体 body: | { "event": "{{ .InvolvedObject.Kind }}", "name": "{{ .InvolvedObject.Name }}", "namespace": "{{ .InvolvedObject.Namespace }}", "severity": "{{ .Severity }}", "message": "{{ .Message }}", "timestamp": "{{ .Timestamp }}", "revision": "{{ .Revision }}", "summary": "{{ .Summary }}" } ``` --- ## 六、Webhook Receiver:接收外部触发 ### 用途 ``` 正常流程: Git push → Flux 检测(interval间隔)→ 同步 加 Receiver: Git push → Git Webhook → Flux Receiver → 立即同步 → 不用等 interval,即时响应 ``` ### 创建 Receiver ```yaml apiVersion: notification.toolkit.fluxcd.io/v1 kind: Receiver metadata: name: github-receiver namespace: flux-system spec: type: github # GitHub Webhook events: - push # 监听 push 事件 # 关联的资源 resources: - kind: GitRepository name: myapp-deploy namespace: flux-system # Webhook 密钥 secretRef: name: receiver-token ``` ```bash # 创建 Webhook 密钥 kubectl create secret generic receiver-token \ --namespace=flux-system \ --from-literal=token=my-webhook-secret ``` ### 暴露 Receiver 服务 ```bash # Flux 自动创建 Receiver Service kubectl get svc -n flux-system # webhook-receiver ClusterIP # 创建 Ingress 暴露到公网 kubectl apply -f - **培训要点**:Receiver 把 Flux 的同步延迟从分钟级降到秒级。没有 Receiver 时,Flux 按 `interval`(通常1分钟)轮询 Git;有了 Receiver,Git push 后 Webhook 直接触发同步。 --- ## 七、通知过滤与严重级别 ### 严重级别 | 级别 | 含义 | 示例事件 | |------|------|---------| | error | 错误 | 同步失败、镜像拉取失败 | | warning | 警告 | 健康检查不通过 | | info | 信息 | 同步成功、漂移修复 | ### 精确过滤 ```yaml # 只通知生产环境的事件 apiVersion: notification.toolkit.fluxcd.io/v1beta3 kind: Alert metadata: name: prod-only-alerts namespace: flux-system spec: providerRef: name: slack eventSources: # 只监控特定 Kustomization - kind: Kustomization name: "myapp-prod" namespace: flux-system - kind: HelmRelease name: "redis-prod" namespace: redis eventSeverity: - error # 生产环境错误才通知 - warning # 排除 dev 环境的事件 # 通过不在 eventSources 中列出 dev 的资源来实现 ``` --- ## 八、本篇要点回顾 1. 通知三件套:Provider(渠道)+ Alert(规则)+ Receiver(外部触发) 2. 支持 Slack/钉钉/企微/Teams/Discord/Generic Webhook 3. `eventSeverity` 控制通知级别:只通知 error 还是也通知 info 4. `eventSources` 精确控制监听哪些资源的哪些事件 5. Receiver 接收 Git Webhook,把同步延迟从分钟级降到秒级 6. 自定义模板可定制通知消息的格式和内容 **下一篇预告**:GitOps 进阶篇开始:《密钥管理:Sealed Secrets、SOPS 与 External Secrets》。

优秀的个人博客,低调大师

低代码集成Java系列:高效构建自定义插件

前言 随着软件开发的快速发展和需求的不断增长,开发人员面临着更多的压力和挑战。传统的开发方法需要花费大量的时间和精力,而低代码开发平台的出现为开发人员提供了一种更加高效、快速的开发方式。今天小编就以构建命令插件为例,展示如何使用Java语言高效构建自定义插件。 环境准备 活字格插件构建工具-Java版(forguncyJavaPluginGenerator) 活字格设计器(v10.0版本及以上) IDE编译器(例如IntelliJ IDEA Community Edition) Java运行时环境(Java Runtime Environment) JDK8.0版本及以上 插件生成器 打开活字格插件构建工具-Java版链接(forguncyJavaPluginGenerator),下载【活字格Java扩展创建工具】。推荐使用压缩包版本创建。 打开【forguncyJavaExtensionGenerateTool.exe】,在如下界面配置插件的基础信息: 点击创建服务端命令插件,创建完成后,在设置的对应目录下会生成工程文件: 接下来使用IDE编译器打开MyPlugin工程,打开后,工程目录如下图: 至此就完成了前期的准备工作,下面我们来进行代码逻辑的编写。 代码实现 添加依赖 在实现代码之前,我们先要增加一些活字格的相关依赖,如下图我们需要给pom文件中添加如下依赖: 插件的图标和Logo替换Icon.png和PluginLogo.png即可。 而【PluginConfig.json】用于对插件的信息做基本的配置: { "assembly": [], // 如需要加载其他类 "javascript": [], // 如需加载其他JavaScript文件 "css": [], // 如需加载其他css文件 "image": "resources/PluginLogo.png", // 需要加载图片的相对路径 "description": "这是一个活字格插件", // 插件的文本描述信息 "description_cn": "这是一个活字格插件", // 插件的中文文本描述信息 "name": "MyPlugin", // 插件名称 "name_cn": "我的插件", // 插件中午名称 "pluginType": "command", // 插件类型,当前为命令类型插件 "guid": "fefeb164-ab98-48c8-b309-b5410052e504", // 插件唯一标识GUID,建议勿修改 "version": "1.0.0.0", // 插件版本 "dependenceVersion": "10.0.0.0" // 插件支持依赖最低活字格版本 } 编写核心代码逻辑 在完成上述配置之后,就可以编写插件逻辑了。下面是插件的一段示例代码,主要是通过5个参数(AppSecret、请求ID、时间戳、数据和签名结果)生成一段随机数签名。 package org.example; import com.grapecity.forguncy.LoggerContext; import com.grapecity.forguncy.commands.ICommandExecutableInServerSide; import com.grapecity.forguncy.commands.IServerCommandExecuteContext; import com.grapecity.forguncy.commands.annotation.ResultToProperty; import com.grapecity.forguncy.commands.annotation.common.Category; import com.grapecity.forguncy.commands.entity.Command; import com.grapecity.forguncy.commands.entity.ExecuteResult; import com.grapecity.forguncy.commands.enumeration.CommandScope; import com.grapecity.forguncy.plugincommon.common.annotation.*; import lombok.Data; import org.apache.commons.codec.binary.Base64; import java.io.BufferedReader; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import javax.servlet.http.HttpServletRequest; @Data @Icon( uri= "resources/Icon.png") @Category(category = "程杰合集") public class MyPlugin extends Command implements ICommandExecutableInServerSide { private static final char[] DIGITS = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' }; @DisplayName(displayName = "AppSecret") @FormulaProperty @Required private String appSecret; @DisplayName(displayName = "请求ID") @FormulaProperty @Required private String requestId; @DisplayName(displayName = "时间戳") @FormulaProperty @Required private String timestamp; @DisplayName(displayName = "数据") @FormulaProperty @Required private String data; @ResultToProperty @FormulaProperty @DisplayName(displayName = "签名结果") private String resultTo = "结果"; @Override public ExecuteResult execute(IServerCommandExecuteContext dataContext) { Long innerTimestamp = Long.parseLong(timestamp); String res = null; try { res = sign(appSecret, requestId, innerTimestamp, data); } catch (Exception e) { throw new RuntimeException(e); } try { dataContext.getParameters().put(resultTo, res); } catch (Exception e) { throw new RuntimeException(e); } ExecuteResult executeResult = new ExecuteResult(); executeResult.getReturnValues().put("结果", res); return executeResult; } @Override public boolean getDesignerPropertyVisible(String propertyName, CommandScope commandScope) { return super.getDesignerPropertyVisible(propertyName, commandScope); } @Override public String toString() { return "签名程杰"; } public static String sign(String appSecret, String requestId, Long timestamp, String data) throws Exception{ // 1.签名参数按自然升序排列,拼接上data StringBuilder sb = new StringBuilder(); sb.append("appSecret=").append(appSecret).append("&") .append("requestId=").append(requestId).append("&") .append("timestamp=").append(timestamp) .append(data); // 2.对签名字符串base64编码后获取32位md5值 // 2.对签名字符串base64编码后获取32位md5值 String base64Encode = base64Encode(sb.toString().getBytes("UTF-8")); String md5Value = md5(base64Encode); // 3.将得到的MD5值进行sha1散列,转换为16进制字符串 String sign = sha1(md5Value); return sign; } /** * 对字符串进行MD5加密,得到32位MD5值 * @param text 明文 * @return 密文 */ public static String md5(String text) { try { MessageDigest msgDigest = MessageDigest.getInstance("MD5"); msgDigest.update(text.getBytes("UTF-8")); byte[] bytes = msgDigest.digest(); // 转成16进制 return new String(encodeHex(bytes)); } catch (NoSuchAlgorithmException e) { throw new IllegalStateException("System doesn't support MD5 algorithm."); } catch (UnsupportedEncodingException e) { throw new IllegalStateException("System doesn't support your EncodingException."); } } /*** * SHA加密 * @return */ public static String sha1(String content) throws Exception { MessageDigest sha = MessageDigest.getInstance("SHA1"); byte[] byteArray = content.getBytes("UTF-8"); return new String(encodeHex(sha.digest(byteArray))); } /** * base64编码 * * @param content * @return * @throws Exception */ public static String base64Encode(byte[] content) throws Exception { return Base64.encodeBase64String(content).replaceAll("(\\\r\\\n|\\\r|\\\n|\\\n\\\r)", ""); } /** * base64解码 * * @param content * @return * @throws Exception */ public static byte[] base64Decode(String content) throws Exception { return Base64.decodeBase64(content); } /** * 转换成16进制 * @param data * @return */ private static char[] encodeHex(byte[] data) { int l = data.length; char[] out = new char[l << 1]; // two characters form the hex value. for (int i = 0, j = 0; i < l; i++) { out[j++] = DIGITS[(0xF0 & data[i]) >>> 4]; out[j++] = DIGITS[0x0F & data[i]]; } return out; } public static String getPostData(HttpServletRequest request) { StringBuilder data = new StringBuilder(); String line; BufferedReader reader; try { reader = request.getReader(); while (null != (line = reader.readLine())) { data.append(line); } } catch (IOException e) { return null; } return data.toString(); } } 使用maven打包插件 代码写完后,将整个项目打包:在此处点击【clean】,然后点击【install】: 接着在【target】目录会出现打包产物: 紧接着把打包后的zip插件安装到活字格设计器使用。 新建命令,在命令选择中就可以找到刚才打包的插件。 填写参数: 可以在服务端命令中进行测试: 可以看到,上图的测试结果中返回了一段随机数签名。这样,一个使用Java语言构建的插件就已经开发完成啦。 总结 以上就是如何使用Java如何在低代码平台中开发一个命令插件的全过程,如果您想了解更多的信息,欢迎点击这里查看。 扩展链接: 从表单驱动到模型驱动,解读低代码开发平台的发展趋势 低代码开发平台是什么? 基于分支的版本管理,帮助低代码从项目交付走向定制化产品开发

资源下载

更多资源
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长,特征是大鼻子、头戴帽子、身穿背带裤,还留着胡子。与他的双胞胎兄弟路易基一起,长年担任任天堂的招牌角色。

Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能,例如代码缩略图,Python的插件,代码段等。还可自定义键绑定,菜单和工具栏。Sublime Text 的主要功能包括:拼写检查,书签,完整的 Python API , Goto 功能,即时项目切换,多选择,多窗口等等。Sublime Text 是一个跨平台的编辑器,同时支持Windows、Linux、Mac OS X等操作系统。

用户登录
用户注册