华为云首页用户手册

ASTRO轻应用 ASTROZERO-如何配置事件流:结果验证

时间：2023-12-27 16:08:00

ASTRO轻应用 ASTROZERO 消息事件

结果验证

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