文档

任务管理

更新时间:

本文介绍如何在任务管理页面对调度任务进行一系列操作。

创建调度任务

重要

创建任务前,请确保您已经创建了任务分组。更多信息,请参见应用管理

  1. 登录EDAS控制台

  2. 在左侧导航栏,单击任务调度

  3. 在顶部菜单栏选择地域。

  4. 在左侧导航栏,选择任务管理

  5. 任务管理页面,选择目标命名空间,单击创建任务。在基本配置配置向导页,配置调度任务的相关信息,然后单击下一步

    创建任务-基本配置

    基本配置参数说明如下:

    配置名称

    说明

    任务名

    自定义任务名称。

    描述

    任务描述,尽量简洁地描述业务,便于后续搜索。

    应用ID

    任务所属分组。可以在下拉列表中选择。

    任务类型

    指任务所实现的语言,当前支持javashellpythongohttpxxljob和、dataWorksspringschedule类型,其中shellpythongo会弹出编辑框,在编辑框中编写任务脚本。

    Processor类名

    说明

    任务类型选择java时出现。

    JobProcessor的全路径,例如xxx.xxx.xxx.HelloProcessor

    执行模式

    执行模式,这里特指任务执行的模式,当前支持以下模式。

    • 单机运行:随机选一台机器执行。

    • 广播运行:所有机器同时执行并等待全部结束。

    • 可视化MapReduce:Map模型,子任务300以下,有子任务列表。

      专业版可支持至1,000以下,且支持业务关键字查询。

    • MapReduce:属于常规MapReduce模型任务,能支持超大数量的子任务并行处理,仅可查询子任务运行汇总信息,建议子任务100W以下时选择。

    • 分片运行:类似elastic-job模型,配置分片参数,可以将分片平均分给多个客户端执行。支持多语言版本。

    说明

    当选择不同执行模式后,高级设置中的参数会随之变化。

    任务参数

    任意字符串,可以在运行时通过上下文获取。

    高级配置参数说明如下:

    参数

    适用的执行模式

    解释

    默认值

    实例失败重试次数

    通用

    任务运行失败自动重试的次数。

    说明

    正在执行任务的机器重启,任务会变成失败状态,如果想立即重跑,可以配置该参数。

    0

    实例失败重试间隔

    通用

    每次失败重试的间隔。单位:秒。

    30

    实例并发数

    通用

    同一个Job同一时间运行的实例个数。1表示不允许重复执行。

    1

    子任务单机并发数

    • 并行计算

    • 内存网格

    • 网格计算

    分布式模型,单台机器并发消费子任务的个数。

    5

    子任务失败重试次数

    • 并行计算

    • 内存网格

    • 网格计算

    分布式模型,子任务失败自动重试的次数。

    0

    子任务失败重试间隔

    • 并行计算

    • 内存网格

    • 网格计算

    分布式模型,子任务失败自动重试的间隔。单位:秒。

    0

    子任务分发方式

    • 并行计算

    • 内存网格

    • 网格计算

    • 推模型:每台机器平均分配子任务。

    • 拉模型: 每台机器主动拉取子任务,没有木桶效应。拉取过程中,所有子任务会缓存在Master节点,对内存有压力,建议子任务数不超过10,000。

    推模型

    子任务单次拉取数(仅适用于拉模型)

    • 并行计算

    • 内存网格

    • 网格计算

    Slave节点每次向Master节点拉取多少个子任务。

    5

    子任务队列容量(仅适用于拉模型)

    • 并行计算

    • 内存网格

    • 网格计算

    Slave节点缓存子任务的队列大小。

    10

    子任务全局并发数(仅适用于拉模型)

    • 并行计算

    • 内存网格

    • 网格计算

    分布式拉模型支持全局子任务并发数,可以进行限流。

    1,000

  6. 定时配置配置向导页,设置定时参数和高级配置参数,然后单击下一步

    创建任务-定时配置

    定时参数说明如下:

    配置项

    说明

    时间类型

    • none:无调度方式,一般通过工作流触发。

    • cron:Cron表达式。

    • api:通过API触发。

    • fixed_rate:固定频率。

    • second_delay:秒级固定延迟。

    • onetime:一次性任务。

    • unix cron:unix系统下的cron表达式。

    cron表达式(仅适用于cron时间类型)

    填写Cron表达式。可以直接按照Cron语法填写,也可以使用工具生成并验证。

    固定频率(仅适用于fixed_rate时间类型)

    填写固定频率,单位为秒,只支持60秒以上。例如200表示每200s调度一次。

    固定延迟(仅适用于second_delay时间类型)

    填写固定延迟,单位为秒。范围为1秒~60秒。例如5表示延迟5秒触发调度。

    调度时间(仅适用于onetime时间类型)

    填写任务指定的执行时间。例如:2023-7-13 00:00:00

    unix cron表达式(仅适用于unix cron时间类型)

    填写unix系统格式的cron表达式。

    高级配置参数说明如下:

    配置项

    说明

    时间偏移

    数据时间相对于调度时间的偏移,可以在调度时从上下文获取该值。

    时区

    可以根据实际情况选择不同时区,包括一些常用国家或地区,也包括标准的GMT表达方式。

  7. 通知配置配置向导页,设置报警参数及联系人,然后单击完成

    创建任务-报警配置
  8. 返回任务管理页面,查看刚才创建的任务是否已存在,且参数是否和配置一致。

    说明

    调度任务创建完成后,默认为启用状态。您也可以根据实际情况禁用、再启用该任务。具体操作,请参见启用和禁用调度任务

编辑调度任务

  1. 任务管理页面,单击目标任务的操作列下的编辑

    1
  2. 编辑面板,设置基本配置、定时配置和报警配置参数。

    说明

    任务分组和任务类型在编辑时不可修改。其它参数配置规则和创建调度任务时一致。

执行调度任务

任务管理页面任务列表的操作列下的运行一次,可以执行一次该调度任务。

2

启用和禁用调度任务

单个调度任务启用和禁用

  1. 任务管理页面,单击目标任务操作列下的更多图标,然后单击禁用或者启用

    3
  2. 在确认对话框单击确认

批量启用和禁用调度任务

如果是专业版应用,您可以批量启用和禁用调度任务。在任务管理页面,勾选目标任务,然后单击任务列表下方的批量禁用批量启用

4

复制调度任务

任务管理页面,单击目标任务操作列下的更多图标,然后单击复制。可以复制该调度任务的配置,您可以编辑复制的任务,生成新的调度任务。

5

重刷调度任务

如果您的业务发生变更,如数据库增加一个字段或者上一个月数据有错误,需要把过去一段时间的任务重新执行一遍,可以重刷调度任务数据。

说明

任务和工作流都支持重刷数据(只支持天级别的调度周期)。

如果您之前执行的某个调度任务的数据出现偏差或遗漏,您可以通过重新设置执行参数并执行某个调度任务属性、获取数据。

  1. 任务管理页面,单击目标任务操作列下的更多图标,然后单击重刷任务

  2. 重刷任务面板,设置起止日期数据时间,单击确定

    • 起止日期:指定重刷的日期区间。

    • 数据时间:指定重刷日期区间内的重刷时间。

    6

    示例重刷配置如下:

    • 当前时间为2019-01-01 10:00:00。

    • 重刷任务的起止日期为2018-10-01~2018-10-07,默认从2018年10月1日00:00:00起,到2018年10月7日23:59:59结束。

    • 数据时间为11:11:11。

    则该任务会被重刷7次,生成7个实例。

    序号

    调度时间

    数据时间

    1

    2019.1.1 10:00:00

    2018.10.1 11:11:11

    2

    2019.1.1 10:00:00

    2018.10.2 11:11:11

    3

    2019.1.1 10:00:00

    2018.10.3 11:11:11

    4

    2019.1.1 10:00:00

    2018.10.4 11:11:11

    5

    2019.1.1 10:00:00

    2018.10.5 11:11:11

    6

    2019.1.1 10:00:00

    2018.10.6 11:11:11

    7

    2019.1.1 10:00:00

    2018.10.7 11:11:11

查看调度任务的执行记录和操作记录

  • 查看执行记录:在任务管理页面,单击目标任务操作列下的更多图标,单击历史记录,查看该调度任务的执行记录。7

  • 查看操作记录:在任务管理页面,单目标任务操作列下的更多图标,单击操作记录,查看该调度任务的管理操作记录。8

删除调度任务

  1. 任务管理页面,单击目标任务操作列下的更多图标,单击删除

    6
  2. 在弹出的确认对话框中单击确认

导入或导出任务

  1. 任务管理页面,选择应用(专业版的应用)。

    1
  2. 单击导入任务或者导出任务即可。