数据开发治理平台 WeData 事件管理

编排空间支持事件触发调度功能,用户在工作流任务中配置监听事件依赖后,该任务需要等待事件达到后方可执行。

相关产品
数据开发治理平台 WeData 产品页,含版本规格、价格与购买入口。

一、事件概述

·事件:用户基于业务需求定义的消息,用于触发任务实例执行,一个事件可支持多个任务实例触发运行。

·事件触发:任务调度系统通过外部事件触发任务实例运行,例如外部调度系统、文件事件等。

二、事件触发流程

数据开发支持事件触发调度功能,适用于任务依赖某个事件触发执行的场景,由触发程序、触发事件和监听任务组成,首先在项目下需要根据业务定义触发事件,然后编写触发程序发送事件,任务监听到事件触达后即可运行。

三、操作步骤

1. 登录 数据开发治理平台 WeData 控制台。

2. 单击左侧的项目列表。

3. 选择对应的项目,并单击进入数据开发模块。

4. 在左侧菜单中单击事件管理。

四、新建事件

1. 事件管理页面可以通过新建或导入事件的方式创建事件。单击左上角新建按钮后,在弹框中配置事件信息。

2. 进入新建事件界面,配置项包括事件名称、周期类型、事件触发有效时间以及描述信息。

配置信息:

信息 描述
事件名称 用户基于业务需求定义的消息,用于触发任务实例执行,一个事件可支持触发多个任务实例运行,一个事件可支持触发多个任务实例运行。
周期类型 与监听事件的周期类型对应,事件实例和任务实例的计划调度时间相同时方能触发。事件的周期类型与任务的周期类型对应关系为:分钟 > 分钟(对应时间格式:yyyyMMddHHmm)小时 > 小时(对应时间格式:yyyyMMddHH)天 > 天、周、月、年(对应时间格式:yyyyMMdd)
事件触发有效时间 事件最大的存活时间,逾期将自动销毁。

五、事件操作

事件创建完成后,通过各项操作功能可以将其使用管理起来。

功能信息:

信息 描述
新建 监听事件创建。
触发 勾选列表中已创建的监听事件,如果对应监听事件已关联了任务调度,可以通过触发功能进行事件批量触发。
删除 勾选列表中的监听事件进行删除。
编辑 可修改事件触发有效时间和描述。
手动触发 手动触发单个监听事件。
关联任务 查看事件关联的调度任务。
事件实例 跳转到 实例运维 页面,查看事件触发后生成的事件实例。
删除 删除单个实例。
搜索 在列表中按事件名称搜索监听事件。
刷新 刷新当前事件列表。
导出 将事件导出为 CSV 文件,可选择导出全部事件、导出搜索结果或导出选中事件。

六、触发方式1:手动触发

在事件管理页面,单击操作列的手动触发按钮,选择需要触发的实例数据时间进行操作。

七、触发方式2:通过 shell 脚本触发

1. 创建一个 shell 任务,在调度配置 > 事件调度中,打开配置事件驱动 hook。

2. 设置事件变量,例如设置为 events。

3. 在 shell 代码中配置条件,若满足所属的触发条件,则执行固定 echo 语句,格式举例:echo events="EventA,20220713;EventB,20220713;",即在任务成功运行后可触发 EventA 和 EventB 的事件。

·events 表示定义的事件变量。

·EventA 和 EventB 为需要触发的事件。

·20220713表示需要触发的实例数据时间。

八、触发方式3:调用接口触发

调用 TriggerDsEvent 接口进行触发,接口介绍可参见 触发事件。

赞 (0)
上一篇 4天前
下一篇 4天前