华为云ASTRO轻应用-如何配置事件流:结果验证
时间:2025-03-03 16:45:34
结果验证
- 创建一个服务编排“fire_alarm”,创建后启用该服务编排,实现当kafka中出现高温报警事件时,AstroZero需要接收该事件,再向第三方系统发送该告警邮件。
- 鼠标放在应用下的Logic文件夹上,单击“+”,选择“服务编排”。
- 选择“创建一个新的服务编排”,设置标签和名称为“fire_alarm”,单击“添加”。
- 在服务编排设计页面左侧,拖拽“逻辑”下的“等待”图元至画布中。
- 单击
,在“可编辑的事件”中,单击“新增”,新增“event0”分支。
配置该分支事件为高温报警事件,当系统中出现该事件时,会执行该分支。图9 配置等待图元 - 拖拽“基本”下的“发送邮件”图元至画布中。
- 单击
,设置发送邮件参数。
配置高温报警邮件的主题和内容,地址填入第三方系统的邮件接收地址。图10 配置发送邮件图元- 直接编辑:手动设置邮件信息。
- 基于模板:基于同一账号或基线中已有的邮件模板,设置邮件主题和内容,方便用户增加效率。
- 模板:选择“基于模板”时,需要选择邮件模板。
- 主题:设置邮件标题。
- 选中“直接编辑”时,需要配置邮件标题。
- 选中“基于模板”时,该参数配置区域置灰。
- 内容:设置邮件内容。
- 选中“直接编辑”时,需要配置邮件内容。
- 选中“基于模板”时,该参数配置区域置灰。
- 自定义变量:选中“基于模板”时,需要配置模板中的参数。在“值”中,直接输入参数取值或者从全局上下文拖拽变量。
- 地址:接收人的邮箱地址。
- 字符串:直接输入分号分隔的字符串或从全局上下文拖拽变量。
- 集合:从全局上下文拖拽集合变量。
- 抄送:抄送人员的邮箱地址,直接输入分号分隔的字符串或者从全局上下文拖拽变量。
- 密送:密送发送人员的邮箱地址,直接输入分号分隔的字符串或者从全局上下文拖拽变量。
- 按照下图连接所有图元,等待图元和发送邮件图元之间选择“event0”分支。
图11 连接所有图元
- 单击页面上方的
,保存服务编排。
- 保存成功后,单击
,启用服务编排。
- 创建一个服务编排“send_fire_event”,将温度监测事件“temperature”中位置参数“position”赋值为仓储公司某区域,温度“temperature”赋值为70度,启用该Flow,用于模拟事件发送。
- 鼠标放在应用下的Logic文件夹上,单击“+”,选择“服务编排”。
- 选择“创建一个新的服务编排”,设置标签和名称为“send_fire_event”,单击“添加”。
- 在服务编排编辑器页面左侧,拖拽“基本”下的“发送事件”图元至画布中。
- 单击
,设置发送事件参数。
图12 配置发送事件图元- 事件:选择待发送的事件。
- 分区字段:从事件中选择一个自定义参数用作Kafka的分区字段,则根据该字段值进行路由,相同的值将路由到同一个Kafka分区。如果不指定,则默认随机路由到不同Kafka分区,从而提升并发处理性能。
- 发送到外部:系统内部有配置与AstroZero相连Kafka的固定Topic“__BINGO_SYS_TOPIC”。若不勾选“发送到外部”,表示将事件数据发到默认的Topic上。若勾选“发送到外部”,则表示将事件数据发送到与AstroZero相连Kafka的其他Topic上。
- 延迟到事务结束(提交或回滚)后才发送:是否延迟到该服务编排事务结束后,才发送事件。
- 主题:勾选“发送到外部”时,才显示该参数,表示非系统配置的默认Topic。
- 目标/源:配置事件数据。
本示例中,“目标”请从下拉框中选择事件的自定义参数“temperature”和“position”,在“源”中给目标赋值。
- 按照下图连接所有图元。
图13 连接图元
- 单击页面上方的
,保存服务编排。
- 保存成功后,单击
,启用服务编排。
- 在“事件流”列表页面,单击该事件流程所在行的
,运行该事件流程。
- 单击服务编排“send_fire_event”编辑器上方的
,执行服务编排。
不用输入任何输入参数,直接单击“运行”。
- 参考上一步,执行服务编排“fire_alarm”。
不用输入任何输入参数,单击“运行”。
- 打开第三方系统邮箱,成功收到高温警报邮件,验证成功。
support.huaweicloud.com/usermanual-astrozero/astrozero_05_0084.html