管理触发器

您可以通过触发器预设触发式任务运行的条件,满足条件的任务可被自动触发。本文将为您介绍新建和使用触发器的具体操作。

前提条件

使用限制

  • 仅华东1(杭州)、华北6(乌兰察布)、华南1(深圳)地域支持使用该功能。

  • 如需使用该功能,您可通过提交工单申请白名单,我们将评估您的申请,评估通过后方可使用。

  • 触发器仅适用于生产环境,且只有发布到运维中心的触发式工作流才可以通过触发器进行触发运行。

  • DataWorks专业版以上支持使用该功能。

    说明

    如果您的当前版本不支持此功能,您可以升级DataWorks版本到专业版或更高版本

  • 仅支持以下的OSS事件注册触发器。后续可根据不同的事件类型上传文件,来触发运行触发式工作流。

进入触发器管理页面

  1. 进入运维中心页面。

    登录DataWorks控制台,切换至目标地域后,单击左侧导航栏的数据开发与运维 > 运维中心,在下拉框中选择对应工作空间后单击进入运维中心

  2. 在运维中心左侧导航栏单击其他 > 调度设置,然后切换至触发器管理页签。

新建触发器

触发器管理页签新建触发器。

  1. 单击新建触发器按钮,进入新建触发器配置页面。

  2. 根据以下说明完成相关参数的配置。

    参数

    配置说明

    适用工作空间

    选择当前地域下需要应用触发器的工作空间。

    适用环境

    触发器只适用于生产环境,请谨慎操作。

    责任人

    下拉配置触发器的责任人。

    触发器类型

    仅支持事件触发

    事件源

    仅支持对象存储OSS事件源acs.oss

    说明

    事件类型

    支持以下三种事件类型:

    Bucket名称

    从下拉列表中选择作为事件源的OSS Bucket名称。如未创建,可创建OSS存储空间

    文件名称

    指定触发事件的文件名称,支持通配符匹配:

    • 文件前缀匹配:

      • 配置示例:task*

      • 配置说明:您在OSS上传以task为前缀的文件(例如task10.txt)时,可触发事件。

    • 文件后缀匹配:

      • 配置示例:*task.txt

      • 配置说明:您在OSS上传以task.txt为后缀的文件(例如work_task.txt)时,可触发事件。

    • 灵活匹配:

      • 配置示例:*task*

      • 配置说明:您在OSS上传task字符相关的文件(例如work_task.txt)时,可触发事件。

  3. 单击确认,完成触发器的创建。

    说明

    触发器创建成功后,会自动在事件总线EventBridge中生成一条事件规则,用于接收OSS指定路径的事件消息。

使用触发器

若需通过事件触发执行工作流任务,可在新建调度工作流时选择触发式工作流,并在发布时引用对应触发器。后续可通过该触发器生成的事件规则触发并执行工作流任务。

引用触发器

  1. 新建触发式工作流

  2. 配置发布触发式工作流时,在调度策略中配置您所创建的触发器。

  3. 触发式调度工作流发布成功后会生成触发式工作流任务。

触发工作流执行

  1. 根据新建触发器的事件类型,上传文件到您在触发器中配置的OSS Bucket。

  2. 事件总线EventBridge接收到OSS指定路径的上传文件的事件消息后,会触发运维中心手动任务中的触发式工作流去执行。

  3. 您可在运维中心查看并管理已执行的触发式工作流实例

管理触发器

触发器管理页签,找到目标触发器后,可进行查看引用任务、修改和版本查看及回滚等相关操作。

  • 查看引用任务:当触发器被触发式调度工作流所引用时,您可单击操作栏中的查看引用任务 ,在查看引用任务页面中查看该触发器被哪些触发式调度工作流引用。

  • 修改触发器:单击操作栏中的修改 ,在修改触发器页面中编辑该触发器的相关信息后,单击确认完成修改。

    说明

    修改完成后,系统会自动为触发器创建一个新版本。

  • 查看版本

    1. 单击操作栏中的版本,可在查看版本页面查看该触发器的所有历史版本。

    2. 可单击操作栏中的查看了解某个版本的触发器详情。

    3. 支持版本回滚。如需回滚到某个历史版本,单击历史版本后面的回滚,在弹出的提示框中填写回滚备注信息后,确定完成回滚。

      说明

      回滚时,系统会根据您选择的回滚版本自动生成一个新版本。

  • 删除触发器:删除触发器前,请确保已下线并删除引用该触发器的所有引用任务。然后单击删除按钮,并在提示框中确认删除操作。