DataWorks的OpenEvent旨在将DataWorks的各类状态变更情况以消息的方式触达到用户,便于用户订阅消息并做出个性化的响应。例如,您可以通过OpenEvent订阅表变更,从而实现核心表的实时监控;通过OpenEvent订阅任务变更,实现定制化开发实时任务大屏的数据监控。本文为您介绍OpenEvent支持订阅的事件类型与配置流程。
前提条件
目前OpenEvent面向DataWorks企业版用户,华北2(北京)、华东1(杭州)、华东2(上海)、华北3(张家口)、华南1(深圳)、西南1(成都)、美国(硅谷)、美国(弗吉尼亚)、德国(法兰克福)、日本(东京)、中国(香港)、新加坡地域支持该功能。
OpenEvent通过EventBridge实现消息的订阅与消费,所以您需要先开通EventBridge产品服务,关于EventBridge产品介绍详情请参见:什么是事件总线EventBridge。
背景信息
DataWorks已开放DataWorks侧核心流程的状态变更消息,并支持将消息推送至OpenEvent服务,您可通过DataWorks的OpenEvent模块对空间消息进行推送管理,并结合事件总线EventBridge服务实现DataWorks事件消息的过滤与消费管理。

相关概念
DataWorks事件消息按照是否可在DataWorks形成流程卡点,分为普通事件和扩展点事件。
DataWorks事件消息按照事件生效范围,将事件划分空间级事件和租户级事件。
支持订阅的事件类型
下表为空间级和租户级分别支持的扩展点事件和普通事件。
空间级事件
数据开发
数据开发消息格式详情请参见:数据开发事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
节点变更 | 新增节点 | 
| 
| 新建节点发布生产 |
更新节点 | 
| 
| |
文件变更 | 删除文件 | 
| 
| 开发环境删除文件,被删除的文件将放入回收站。 |
提交文件 | 
| 
| 在DataStudio提交某个节点、资源或函数。 |
发布文件 | 
| 
| 在DataStudio发布某个已提交节点、资源或函数。 |
运行文件 | 
| 
| 在DataStudio运行节点代码。 |
表变更 | 表提交开发环境 | 
| 
| 表提交扩展点事件:例如在表管理中提交某个表。 |
表发布生产环境 | 
| 
| 表发布扩展点事件:例如在表管理中发布某个表。
说明 仅标准模式工作空间支持在表管理中发布表,因此表发布扩展点事件仅存在于标准模式下。 |
数据集成
数据集成消息格式详情请参见:数据集成事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
节点变更事件 | 开启实时任务 | 
| 
| 在数据集成启动实时任务。 |
批量开启实时任务 | 
| 
| 在数据集成批量启动实时任务。 |
运维中心
运维中心消息格式详情请参见:运维中心事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
节点变更 | 删除节点 | 
| 
| |
下线节点 | 
| 
| 生产环境周期任务直接下线节点。
说明 该操作会同步删除数据开发中的节点,并放入回收站。 |
冻结节点 | 
| 
| 周期任务界面冻结任务。 |
解冻节点 | 
| 
| 周期任务界面解冻任务。 |
节点补数据 | 节点补数据 | 
| 
| |
任务状态变更 | 调度任务状态变更 | 
| 
| 如下场景会触发调度任务状态变更事件: 调度任务下发至数据质量进行数据校验。 调度任务校验分支条件。 任务定时触发、手动触发或事件触发。任务状态将从等待资源变更为运行中。 调度任务执行完成(即执行成功或失败)。任务状态将从运行中变更为执行成功。 调度任务执行失败后选择重新执行任务。任务状态将从执行失败变更为运行中。 调度定时任务。任务状态会变更为等待定时时间(DueTime或cycleTime)到来。
|
实例变更 | 冻结实例 | 
| 
| 在运维中心的周期实例列表对某个实例进行以下操作后,会触发相应事件。 冻结实例。 解冻实例。 终止实例。 重跑实例。 置成功实例。 移除实例指定上游依赖。
|
解冻实例 | 
| 
|
终止实例 | 
| 
|
重跑实例 | 
| 
|
置成功实例 | 
| 
|
移除实例指定上游依赖 | 
| 
|
冻结实例前置事件 | 
| 
| 在运维中心的周期实例列表对某个实例单击某个操作时,会触发相应前置事件。 冻结实例。 解冻实例。 重跑实例。 置成功实例。 终止实例。
|
解冻实例前置事件 | 
| 
|
重跑实例前置事件 | 
| 
|
置成功实例前置事件 | 
| 
|
杀死实例前置事件 | 
| 
|
删除过期实例 | 
| 
|
工作流状态变更 | 工作流状态变更 | 
| 
| 执行补数据操作时产生的工作流状态监控。 运行手动业务流程时产生的工作流状态监控。
|
监控告警 | 监控告警 | 
| 
| 基线告警示例:某个基线上任务预计完成时间太晚,触发基线告警。 事件告警示例:某个基线上任务运行失败,触发事件告警。 规则告警示例:创建了一个针对孤立节点的报警规则后,当工作流中出现了孤立节点,触发了此规则告警。
|
安全中心
安全中心消息格式详情请参见:安全中心事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
申请单创建/审批 | 创建权限申请单前置事件 | 
| 
| 例如在安全中心内,页面对函数、表、资源,进行权限申请单的创建。 |
完成申请单 | 
| 
| 例如在安全中心内页面,审批所有项目下的表、资源和函数的权限。 |
表权限变更 | 表权限申请 | 
| 
| 例如用户根据需求申请特定表的读取、写入、修改等权限。 |
数据质量
数据质量消息格式详情请参见:数据质量事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
数据质量校验 | 校验结果反馈 | 
| 
| 用户对校验结果的反馈。 例如,在数据治理的数据质量模块,给某个表启用了表行数大于0的规则,页面上用户可以对某次校验结果进行反馈,当用户执行了反馈操作,系统会把用户反馈的内容(校验规则ID、反馈内容等)发送给订阅端。 |
校验完成 | 
| 
| 规则校验完毕发送规则校验结果(是否通过、样本等信息) 例如,在数据治理的数据质量模块,给某个表启用了表行数大于0的规则,触发了规则并且规则校验完毕,会把规则校验结果(是否通过、样本等信息)发送给订阅端。 |
数据质量规则前置 | 批量创建数据质量规则前置事件 | 
| 
| 例如在数据质量内,进入页面的某个表详情页。在规则管理页签进行如下操作时,会触发相应前置事件。 新建多个数据质量监控规则。 修改多个数据质量监控规则。 删除多个数据质量监控规则。 修改某个数据质量监控规则。
|
批量更新数据质量规则前置事件 | 
| 
|
批量删除数据质量规则前置事件 | 
| 
|
更新数据质量规则前置事件 | 
| 
|
数据质量监控前置 | 创建数据质量监控前置事件 | 
| 
| 例如在数据质量内,进入页面的某个表详情页。在质量监控页签进行如下操作时,会触发相应前置事件。 新建数据质量监控。 修改数据质量监控。 克隆数据质量监控。 批量删除数据质量监控。
|
更新数据质量监控前置事件 | 
| 
|
克隆数据质量监控前置事件 | 
| 
|
批量删除数据质量监控前置事件 | 
| 
|
数据质量监控告警订阅前置 | 创建数据质量监控告警订阅前置事件 | 
| 
| 例如在数据质量内,进入页面的某个表详情页。在质量监控页签中对某个质量监控进行告警订阅。 |
更新数据质量监控告警订阅前置事件 | 
| 
| 例如在数据质量内,进入页面的某个表详情页。在质量监控页签中对某个质量监控的告警订阅信息进行修改。 |
删除数据质量监控告警订阅前置事件 | 
| 
| 例如在数据质量内,进入页面的某个表详情页。在质量监控页签中对某个质量监控的告警订阅信息进行删除。 |
租户级事件
管控台
管控台消息格式详情请参见:管控台事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
删除项目空间 | 删除空间前置 | 
| 
| 用户在工作空间列表删除某个工作空间前,将触发该事件。同时,删除项目空间前置事件还会触发相应扩展程序进行流程卡点。 |
删除空间后置 | 
| 
|
上传与下载
上传与下载消息格式详情请参见:上传与下载事件列表。
事件类型 | 事件 | 普通事件 | 扩展点事件 | 示例(产生事件消息的操作) |
数据下载与上传 | 数据下载前置-文件生成 | 
| 
| 当用户在下载中心进行数据下载操作。 在实际的数据下载操作之前,会触发数据下载前置事件,以获取即将进行的下载操作的相关信息。 |
数据下载前置-文件下载 | 
| 
|
数据上传前置 | 
| 
|
应用优势
DataWorks的OpenEvent具备以下优势:
节省运维成本:
通过开启DataWorks开放平台的消息订阅功能,您可以很方便地订阅事件消息。
提升开发效能:
通过在DataWorks界面上创建相关配置,您无需再进行发送消息相关配置,仅需做好相关SDK开发的准备配置工作及订阅消息配置,节省繁杂的手工操作。
实现个性化需求:
DataWorks提供丰富的事件类型,您可以通过订阅不同事件类型的消息,快速感知业务状态变化信息,及时做好个性化响应和决策。