实时计算Flink版默认使用云监控(免费监控服务)或ARMS提供监控报警服务,配置作业指标或事件监控告警,便于您及时发现并处理异常。本文为您介绍使用不同监控服务时如何配置监控告警。
使用限制
部署时提交至Session集群的Flink作业不支持配置监控告警。
批作业暂不支持配置监控告警。
配置方式
使用免费监控服务(云监控)时:您需要跳转到云监控控制台进行配置,详情请参见在云监控控制台配置。
使用ARMS监控服务时:
您可以在Flink开发控制台创建告警规则和模板,支持配置7个监控指标(包括作业失败)的告警,详情请参见在Flink开发控制台配置。
其他监控指标告警需要在ARMS控制台通过PromQL语法自定义配置,详情请参见在ARMS控制台配置。
在云监控控制台配置
仅购买该工作空间的主账号,以及该主账号下具有项目空间权限的RAM用户和RAM角色,可以在云监控上配置告警或订阅事件。
订阅指标告警
在作业运维页面,单击目标作业名称。
在数据曲线页签,单击订阅指标告警,跳转到云监控控制台完成相关配置。
在云监控控制台设置规则描述面板填写参数后,单击确定。
支持批量设置监控告警,您可以选择namespace(Flink项目空间名称)和deploymentID(对应Flink作业部署详情页签的部署作业ID)监控维度。其他参数详情请参见创建报警规则。
说明下拉列表仅显示有监控数据的namespace和deploymentID,无数据时您可以手动填写。
在创建报警规则面板,配置其他报警参数。
资源范围选择实例时,关联资源为工作空间ID(如何查看工作空间ID等信息?),报警规则创建后,关联资源不可更改。其他参数详情请参见创建报警规则。
单击确认。
订阅事件告警
通过配置条件来订阅相关的事件,事件包括系统事件和报警规则产生的阈值事件。
在作业运维页面,单击目标作业名称。
在数据曲线页签,单击订阅事件告警,跳转到云监控控制台完成相关配置。
在创建订阅策略页面,配置相关参数。
具体参数详情请参见管理事件订阅(推荐)。
产品:选择实时计算Flink版。
事件名称:订阅系统事件时,可以选择作业运行失败事件。目前作业运行失败事件仅支持严重(Critical)事件等级。
应用分组:可以选择Flink项目空间。
事件资源:订阅系统事件时,可以在事件资源中通过填写Flink作业的DeploymentID(Flink作业部署详情页签的部署作业ID),对指定作业进行事件告警。
在Flink开发控制台配置
Flink控制台仅支持查看近48小时内告警事件,更长时间的告警事件请在ARMS控制台告警管理中查看。
创建告警规则
进入告警配置入口。
登录实时计算控制台。
在Flink全托管页签,单击目标工作空间操作列下的控制台。
在作业运维页面,单击目标作业名称。
单击告警配置页签。
在告警规则页签,选择
。如果您在配置管理中配置了告警模板,您也可以直接单击告警模板名称,继续后续的步骤,加快配置监控告警的效率。告警模板创建步骤请参见创建告警规则模板。
填写告警规则信息。
类别
参数
描述
具体规则
规则名称
以字母开头,仅包含小写英文字母、数字、下划线(_), 长度限制为3~64个字符。
描述
规则的备注信息。
内容
配置触发报警的条件内容,配置完成后会每间隔指定时间,对指定的指标值与阈值进行计算比较,计算结果满足则自动报警。
其中:
指标:
Restart Count in 1 Minute:1分钟内Job Manager重启次数,单位为次。
Checkpoint Count in 5 Minutes:5分钟内Checkpoint成功次数,单位为个。
Emit Delay:业务延时,即数据发生时间与数据离开Source算子的时间差值,单位为秒。
重要数据发生时间依赖于外部系统中记录的时间戳。如果外部系统里面没时间戳,或者数据写入外部系统时,乱写时间戳,则Emit Delay数值不准确,无法反映真实延时。
IN RPS:每秒输入记录数,单位为条/秒。
OUT RPS:每秒输出记录数,单位为条/秒。
Source IdIe Time:源端未处理数据的时间,单位为毫秒。
Job Failed:作业失败。
时间差:每分钟查询最近时间差分钟内的数据,并与阈值比较。如果历史数据中满足条件,则会触发告警规则。
运算符:支持>=和<=两种。
阈值:与指标进行比较的值。
如果您选择的运算符是>= ,则取纵轴中的MAX值。如果时间差内最大值>=阈值,则触发告警规则。
如果您选择的运算符是<= ,则取纵轴中的MIN值。如果时间差内最小值<= 阈值,则触发告警规则。
例如,配置时间差为5分钟,选择运算符<=,阈值为2。则每次取指标值的历史5分钟的纵轴数据,将其最小值与阈值进行比较,小于等于阈值则触发告警。
生效时间
告警监控的生效时间,可以指定只在白天(9点~18点)生效,默认全天生效。
告警频率
连续多少分钟内只发一次告警。支持1分钟~1440分钟(24小时)。
通知方式
通知方式
支持以下通知方式:
DingTalk:钉钉
Email:邮件
SMS:短信
Webhook:网络服务地址。
Phone:电话。
重要请确保已创建并添加可用的通知对象,否则将导致告警通知方式失败。
告警管理的收费详情请参见告警计费说明。
通知对象
支持同时通知多个通知对象,您可以直接选择或搜索通知对象。在选择通知对象前,您需要先管理通知对象。
具体操作为单击右侧的通知对象管理,然后分别在联系人组、联系人、Webhook和钉钉机器人页签中,单击编辑后单击保存。
如何添加钉钉机器人告警或新建Webhook,详情请参见常见问题。
告警降噪
单击高级配置后,您可以打开告警降噪开关。
打开告警降噪开关后,对于作业可以快速恢复的场景(因集群调度或触发自动调优等场景触发的短期的Failover)则不会向您发送告警,只有连续达到您设置的阈值条件时,才会向您发送告警。
无数据告警
单击高级配置后,您可以打开无数据告警开关并填写连续无数据的时间信息。
打开该功能后,将监测无监控埋点数据汇报场景,如果数据在选择时间段内没有汇报就会触发告警。通常JobManager异常、作业异常停止或者汇报链路异常会导致无监控埋点数据汇报。
单击确定。
保存后的告警规则默认已启用,且出现在告警规则列表中,您可以选择停止、编辑或删除。
创建告警规则模板
进入告警规则模板创建入口。
填写告警模板信息。
类别
参数
描述
具体规则
规则名称
以字母开头,仅包含小写英文字母、数字、下划线(_), 长度限制为3~64个字符。
描述
规则的备注信息。
内容
配置触发报警的条件内容,配置完成后会每间隔指定时间,对指定的指标值与阈值进行计算比较,计算结果满足则自动报警。
其中:
指标:
Restart Count in 1 Minute:1分钟内Job Manager重启次数,单位为次。
Checkpoint Count in 5 Minutes:5分钟内Checkpoint成功次数,单位为个。
Emit Delay:业务延时,即数据发生时间与数据离开Source算子的时间差值,单位为秒。
重要数据发生时间依赖于外部系统中记录的时间戳。如果外部系统里面没时间戳,或者数据写入外部系统时,乱写时间戳,则Emit Delay数值不准确,无法反映真实延时。
IN RPS:每秒输入记录数,单位为条/秒。
OUT RPS:每秒输出记录数,单位为条/秒。
Source IdIe Time:源端未处理数据的时间,单位为毫秒。
Job Failed:作业失败。
时间差:每分钟查询最近时间差分钟内的数据,并与阈值比较。如果历史数据中满足条件,则会触发告警规则。
运算符:支持>=和<=两种。
阈值:与指标进行比较的值。
如果您选择的运算符是>= ,则取纵轴中的MAX值。如果时间差内最大值>=阈值,则触发告警规则。
如果您选择的运算符是<= ,则取纵轴中的MIN值。如果时间差内最小值<= 阈值,则触发告警规则。
例如,配置时间差为5分钟,选择运算符<=,阈值为2。则每次取指标值的历史5分钟的纵轴数据,将其最小值与阈值进行比较,小于等于阈值则触发告警。
生效时间
告警监控的生效时间,可以指定只在白天(9点~18点)生效,默认全天生效。
告警频率
连续多少分钟内只发一次告警。支持1分钟~1440分钟(24小时)。
通知方式
通知方式
支持以下通知方式:
DingTalk:钉钉
Email:邮件
SMS:短信
Webhook:网络服务地址。
Phone:电话。
重要请确保已创建并添加可用的通知对象,否则将导致告警通知方式失败。
告警管理的收费详情请参见告警计费说明。
通知对象
支持同时通知多个通知对象,您可以直接选择或搜索通知对象。在选择通知对象前,您需要先管理通知对象。
具体操作为单击右侧的通知对象管理,然后分别在联系人组、联系人、Webhook和钉钉机器人页签中,单击编辑后单击保存。
如何添加钉钉机器人告警或新建Webhook,详情请参见常见问题。
告警降噪
单击高级配置后,您可以打开告警降噪开关。
打开告警降噪开关后,对于作业可以快速恢复的场景(因集群调度或触发自动调优等场景触发的短期的Failover)则不会向您发送告警,只有连续达到您设置的阈值条件时,才会向您发送告警。
无数据告警
单击高级配置后,您可以打开无数据告警开关并填写连续无数据的时间信息。
打开该功能后,将监测无监控埋点数据汇报场景,如果数据在选择时间段内没有汇报就会触发告警。通常JobManager异常、作业异常停止或者汇报链路异常会导致无监控埋点数据汇报。
单击确定。
创建的告警规则模板会出现在告警规则模板列表中,您可以进行编辑或删除。
在ARMS控制台配置
使用RAM用户、RAM角色等身份访问时,需要具有访问应用实时监控服务权限,详情请参见访问控制概述。
登录实时计算控制台。
单击目标工作空间操作列下的
,进入应用实时监控服务ARMS控制台。上方展示了工作空间名称、工作空间ID,以及对应的Prometheus实例名称,
单击左侧的告警规则,创建告警规则。
检测类型:支持通过自定义PromQL进行自定义指标告警(Flink已支持的告警指标除外)。
筛选条件:通过筛选Flink项目空间和部署作业,进行批量告警配置。命名空间填写项目空间名称,选择全部时表示工作空间下全部项目空间;部署作业填写项目空间下目标作业的部署作业ID(在Flink作业部署详情页签查看),选择全部时表示项目空间下的全部作业。
更多配置参数详情请参见Prometheus告警规则。您也可以创建Prometheus告警规则模板,详情请参见Prometheus告警规则模板。
常见问题
如何在Flink开发控制台添加钉钉机器人告警
添加一个自定义钉钉机器人,并获取它的Webhook地址,详情请参见添加自定义钉钉机器人并获取Webhook地址。
重要安全设置请至少选中自定义关键词,且关键词至少设置为报警才能收到告警信息。
添加通知对象。
在作业运维页面,单击目标作业名称,单击告警配置页签。
选择
或规则模板。在创建规则或创建告警规则模板信息页面,单击通知对象管理。
在钉钉机器人页签,单击添加钉钉机器人。
输入钉钉机器人的名称和地址,单击提交。
返回步骤2的创建规则或创建告警规则模板信息页面,通知方式选择DingTalk,通知对象选择对应的钉钉机器人。
告警规则中的其他参数说明请参见创建告警规则。
单击确定。
如何在Flink开发控制台新建Webhook
在填写告警模板或者规则信息页面,单击通知对象管理。
在Webhook页签,单击新建Webhook。
在新建Webhook页面,输入Webhook信息。
参数
说明
名称
必填,Webhook名称。
URL
必填,网络服务地址。
Headers
可选,请求头,用来存放cookie和token信息。格式为key: value。
说明请确保key与value的冒号后存在空格分隔符。
Params
可选,请求参数,格式为key: value。
说明请确保key与value的冒号后存在空格分隔符。
Body
必填,请求体,用来存放post的参数和参数数据。
您可以在Body字符串中使用$content占位符输出报警内容。
单击确定。
相关文档
实时计算Flink版支持选择云监控(免费监控服务)或ARMS可观测监控Prometheus版监控服务为您提供作业监控告警功能,功能、费用等对比详情请参见云监控与ARMS告警服务功能对比。
支持的监控指标详情请参见监控指标说明。
您可以关闭监控告警或废弃具体指标(使用ARMS监控告警时),以节省费用,后续有需要时可以重新恢复指标采集,具体操作请参见废弃或恢复监控指标。
- 本页导读 (1)