云服务器内容精选

华为云首页用户手册

消息事件

ASTRO轻应用 ASTROZERO-如何自定义事件:事件分类

事件分类在业务流程中，有意义的状态变化都可称为事件。自定义好事件后，可基于该事件实现事件发送、事件订阅，对发送的事件数据进行分析处理等功能。低代码中的事件，分为标准事件和自定义事件两种。标准事件是系统定义好的事件，可直接订阅。标准事件目前有几下几种： Absolute Time Alert：定时器发送的系统事件。 EV_FLOW_STARTED：流程启动，用于记录工作流的启动。 EV_FLOW_TERMINATED：流程终止，用于记录工作流的流程结束。 EV_FLOW_REVOKED：流程撤回，用于记录工作流的撤回。 EV_TASK_STARTED：任务启动，用于记录人工任务启动。 EV_TASK_TERMINATED：任务终止，用于记录人工任务结束。自定义事件是指用户根据自身业务需求，自行定义的事件。例如，在某个公司招聘场景中，招聘人员A和招聘经理B负责面试，招聘经理B负责决定该应聘者是否被录用，录用后，人事部C来给新员工办理各种手续。需要进行软件设计，一旦应聘者被录用后，不需要招聘经理自己去通知人事部，而是创建一个记录应聘者录用结果状态的事件，通过订阅该事件，系统根据状态结果自动发邮件给人事部，通知人事部是否办理入职手续。

ASTRO轻应用 ASTROZERO 消息事件
ASTRO轻应用 ASTROZERO-如何自定义事件:操作步骤

操作步骤参考登录经典应用设计器中操作，登录经典版应用设计器。将鼠标放在应用的某个文件夹上（如Logic），单击“+”，选择“事件”。图1 选择事件选择“创建新事件”，设置基本信息，单击“添加”。图2 创建新事件标签：新建事件的标签名，用于在页面展示。名称：事件在系统中的唯一标识，取值为“命名空间__标签__e”。描述：新建事件的描述信息，建议设置为事件的功能。在事件详情页面的“自定义参数”中，新增自定义参数。自定义参数用于记录有意义的事件状态变化，可以根据需要自行创建。例如，在本章节中创建的是记录应聘者是否被录用状态变化的事件，需要新增应聘者姓名“EmployName”和招聘结果“Result”两个参数字段。在自定义参数中，单击“新建”，进入新增参数页面。标签和名称设置为“EmployName”，字段类型选择“文本”，单击“保存”。图3 “Cutsom Parameters”页签新增参数标签：新建参数的标签名，用于在页面中展示。名称：新增参数在系统中的唯一标识，创建后不可修改。字段类型：新建参数的字段类型，如数字、文本、日期等。描述：新建参数的描述信息，建议配置为参数的功能。是否必填：参数是否必填，勾选后，表示必填字段。参考上述操作，新增标签和名称为“Result”，字段类型为“布尔”的“Result”参数。图4 新增Result参数图5 自定义参数列表在“基本信息”页签，单击“启用”，启用该事件。在“订阅”页签，可查看该事件的订阅者信息。由于事件刚创建，暂没有事件订阅者，下个章节介绍如何订阅该事件。

ASTRO轻应用 ASTROZERO 消息事件
ASTRO轻应用 ASTROZERO-如何订阅事件:通过服务编排订阅事件

通过服务编排订阅事件参考如何开发服务编排中操作，新建一个服务编排。图1 新建一个服务编排标签：新建服务编排的标签名，用于在页面展示。名称：服务编排在系统中的唯一标识，创建后不可修改。类型：新建服务编排的类型，本示例选择“Event Trigger”。 Autolaunched Flow：自启动服务编排，即在接口调用后，会立即执行服务编排中定义的逻辑。 Event Trigger：事件触发的服务编排，在事件触发时，才会开始执行服务编排中定义的逻辑。事件：选择如何自定义事件中创建的事件（请确保事件已启用）。描述：服务编排的描述信息。在服务编排设计页面左侧，选择“逻辑”，拖拽“决策”图元至画布中。该图元类似if语句的判断，用于在服务编排流程中创建判断条件，根据判断结果连线其他图元，决定后续执行何种操作。本示例需要设置应聘者被成功录用、应聘者没被录用和其他三个判断分支。图2 拖拽决策图元至画布中选中决策图元，单击，设置分支条件参数。图3 pass分支条件配置图4 unpass分支条件配置可编辑的结果，即所有的判断条件。系统已预置默认条件，即当其他所有条件均不满足情况下，进入该分支。本示例，需要新增如下两个判断条件： Pass：应聘者被录用。应聘通过时，事件中自定义的布尔类型参数“Result”赋值为全局常量“{!$GlobalConstant.True}”，表示结果为真，即应聘通过。 Unpass：应聘者没有被录用。应聘失败时，事件中自定义的布尔类型参数“Result”赋值为全局常量“{!$GlobalConstant.False}”，表示结果为假，即应聘拒绝。在服务编排设计页面左侧，选择“基本”，拖拽“发送邮件”图元至画布中。发送邮件是发送邮件的接口。本示例中，需要根据录用结果，发送不同的邮件给人事部。录用成功，需要邮件通知人事部办理入职。录用不成功，需要邮件通知人事部告知应聘者应聘失败。事件超时（默认分支），需要邮件通知招聘经理，看其是否给出招聘结果。如下图所示，以应聘者被成功录用为例，设置发送邮件参数。选中发送邮件图元，单击，设置基本信息。图5 设置邮件发送基本信息单击，设置邮件发送参数。图6 配置邮件发送参数邮件配置：可选择“直接编辑”手动设置邮件信息或“基于模板”选择邮件模板。本示例选择“直接编辑”。主题：邮件的标题。内容：邮件内容，需要使用事件变量“EmployResultNotify__e”。地址：接收人的邮箱地址。字符串：表示直接输入。集合：表示可以拖入一个集合变量。参照5中操作，设置应聘者录用失败和超时邮件发送。如图7所示，连接所有元素。图7 连接并设置起始元素在服务编排设计页面上方，单击，保存服务编排。保存成功后，单击，启用服务编排。启用后，当有“EmployResultNotify”事件触发时，即会执行服务编排中定义的逻辑。

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

结果验证创建一个服务编排“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”。不用输入任何输入参数，单击“运行”。打开第三方系统邮箱，成功收到高温警报邮件，验证成功。

ASTRO轻应用 ASTROZERO 消息事件
ASTRO轻应用 ASTROZERO-如何配置事件流:前提条件

前提条件请联系运维，开启事件流License权限。开启后，才可新建、查看并管理事件流。已创建并启用温度监测事件“temperature”，该事件中自定义参数为文本类型“position”和数字类型“temperature”，分别表示位置和温度，具体操作步骤请参考如何自定义事件。已创建并启用高温报警事件“fire_alarm”，该事件中自定义参数为文本类型“positionalarm”和数字类型“temperaturealarm”，分别表示高温报警位置和温度，具体操作步骤请参考如何自定义事件。

ASTRO轻应用 ASTROZERO 消息事件
ASTRO轻应用 ASTROZERO-如何配置事件流:操作步骤

操作步骤参考登录经典应用设计器中操作，登录经典版应用设计器。将鼠标放在应用的某个文件夹上（如Logic），单击“+”，选择“事件流”。开启事件流License权限后，才会有新建事件流的入口。单击“新建”，进入“事件流”页面。在“事件流”页面右侧，单击“设置”，进行数据配置。图2 设置页面窗口长度：事件流处理的数据采集时间间隔，单位为分钟。建议时间间隔不要配置过小，否则系统频繁的建表和执行SQL语句，会影响系统性能。例如：配置为“1”表示spark streaming每隔1分钟去kafka获取事件数据。在“事件流”页面右侧，单击“图元”，拖拽“输入源”中Kafka图元至左侧画布区域，并配置基本信息，单击“保存”。输入源中Kafka图标表示数据来自Kafka。图3 数据来源Kafka基本信息页面标签：新建数据源Kafka的标签名，用于在界面展示。名称：新建数据源Kafka的名称，系统自动生成。事件：需要订阅的事件。例如，配置为温度监测事件“temperature”。从外部接收：是否从外部Kafka接收事件。关闭该开关，从与AstroZero相连的Kafka接收事件。打开该开关，从外部Kafka接收事件。本示例中关闭该开关，使用与AstroZero相连的Kafka。 Kafka集群地址：数据源Kafka的集群地址。多个节点服务器地址可用“,”间隔，格式为“Kafka节点1的ip:节点1端口号,Kafka节点2的ip:节点2端口号,...”。获取Kafka的IP和端口号方法：登录每台Kafka节点服务器，查看“${KAFKA_HOME}/config”目录下，“server.properties”中“listeners”的取值。订阅主题：获取的事件数据来源，即来自于kafka集群的哪个Topic。从“图元”中，拖拽“投影”图元至左侧画布区域数据源Kafka下方，并在弹出的“添加投影器”页面配置基本信息，单击“保存”。图4 “添加投影器”页面标签：新建投影的标签名，用于在界面展示。名称：新建投影的名称，系统自动生成。输入字段：订阅事件的所有事件参数。选择所需的参数，单击，选中的参数会出现在“输出字段”中。输出字段：从订阅事件的事件参数进行筛选后，用到的事件参数。从“图元”中，拖拽“过滤”图元至左侧画布区域投影下方，并在弹出的“添加过滤器”页面配置基本信息和过滤条件，单击“保存”。图5 设置过滤条件标签：新建过滤的标签名，用于在界面展示。名称：新建过滤的名称，系统自动生成。条件设置：设置过滤条件。例如，图中的配置表示提取温度大于60度的事件。字段：上一步筛选后的事件参数。比较符：操作符，直接在下拉框中选择。值：字段值。（可选）从“图元”页面中，拖拽“分组”图元至左侧画布区域过滤器下方，并在弹出的“添加分组器”页面配置基本信息和分组条件，单击“保存”。图6 “添加分组器”页面配置标签：新建分组的标签名，用于在界面展示。名称：新建分组的名称，系统自动生成。分组设置：设置分组条件。例如，图中配置表示按照相同位置的大于60度的温度取温度平均值。在“图元”页面右侧，拖拽输出源中的Kafka图元至左侧画布区域最下方，设置spark streaming输出事件和输出事件数据的接收方，单击“保存”。可以拖拽多个Sink中的Kafka图元，设置多个事件接收方。图7 数据接收方配置标签：数据接收方Kafka的标签名，用于在界面展示。名称：数据接收方Kafka的名称，系统自动生成。事件：spark streaming输出的事件。本示例此处配置为高温报警事件“fire_alarm”。温度监测事件“temperature”中的“position”，对应高温报警事件“fire_alarm”中的“positionalarm”。温度监测事件的“temperature”，对应高温报警事件“fire_alarm”中的“temperaturealarm”。发送到外部：是否发送到外部Kafka。若关闭该开关，表示发送到与AstroZero相连的Kafka。若打开该开关，表示发送到外部Kafka，需要配置“Kafka集群地址”和“订阅主题”。本示例中关闭该开关，使用与AstroZero相连的Kafka。 Kafka集群地址：接收事件的Kafka集群地址，例如10.136.14.56:9092。多个节点服务器地址可用“,”间隔，格式为“Kafka节点1的ip:节点1端口号,Kafka节点2的ip:节点2端口号,...”。获取Kafka的IP和端口号方法：登录每台Kafka节点服务器，查看“${KAFKA_HOME}/config”目录下，“server.properties”中“listeners”的取值。接收事件的kafka集群，不需要一定配置为和AstroZero相连。订阅主题：接收事件数据的kafka Topic，例如__BINGO_PROD_SYS_TOPIC。事件属性/属性、值：配置输出事件与接收事件中，已定义参数的对应关系。单击页面右上方保存按钮，设置“事件流”基本参数。图8 该“事件流”基本参数页面标签：新建事件流的标签名，用于在界面展示。名称：新建事件流的名称，系统自动生成。描述：新建事件流的描述信息。单击页面上方的，启用事件流。

ASTRO轻应用 ASTROZERO 消息事件
ASTRO轻应用 ASTROZERO-如何配置事件流:背景信息

背景信息首先，您需要理解以下概念： kafka：是由Apache开发的一个开源流处理平台，是分布式发布、订阅消息系统。kafka主要用于处理活跃的流数据，一般kafka部署为集群模式。 Topic：用来区分kafka集群中，不同类型消息的主题。例如，应用程序A订阅了Topic1，应用程序B订阅了Topic2而没有订阅Topic1，那么发送到Topic1中的数据将只能被应用程序A读到，而不会被应用程序B读到。 spark streaming：大规模流式数据处理工具，第三方工具。

ASTRO轻应用 ASTROZERO 消息事件