PowerJob/others/doc/ConsoleGuide.md
2020-05-11 21:42:11 +08:00

3.9 KiB
Raw Blame History

STEP3: 任务管理 & 运行状态查看

通过前端控制台管理调度任务,查看运行情况和结果等。

系统首页

展示了系统整体的概览和集群Worker列表。

首页

任务创建

创建需要被调度执行的任务,入口为主页 -> 任务管理 -> 新建任务

任务创建

  • 任务名称:名称,便于记忆与搜索,无特殊用途,请尽量简短(占用数据库字段空间)

  • 任务描述:描述,无特殊作用,请尽量简短(占用数据库字段空间)

  • 任务参数任务处理时能够获取到的参数即各个Processor的process方法入参TaskContext对象的jobParams字段进行一次处理器开发就能理解了

  • 定时信息:由下拉框和输入框组成

    • API -> 不需要填写任何参数(填了也不起作用)
    • CRON -> 填写 CRON 表达式(可以找个在线生成网站生成
    • 固定频率 -> 填写整数,单位毫秒
    • 固定延迟 -> 填写整数,单位毫秒
  • 执行配置由执行类型单机、广播和MapReduce、处理器类型和处理器参数组成后两项相互关联。

    • 内置Java处理器 -> 填写该处理器的全限定类名eg, com.github.kfcfans.oms.processors.demo.MapReduceProcessorDemo
    • SHELL -> 填写需要处理的脚本(直接复制文件内容)或脚本下载连接(http://xxx
    • PYTHON -> 填写完整的python脚本或下载连接http://xxx
  • 运行配置

    • 最大实例数:该任务同时执行的数量(任务和实例就像是类和对象的关系,任务被调度执行后被称为实例)
    • 单机线程并发数该实例执行过程中每个Worker使用的线程数量MapReduce任务生效其余无论填什么都只会使用1个线程或3个线程...
    • 运行时间限制:限定任务的最大运行时间,超时则视为失败,单位毫秒0代表不限制超时时间。
  • 重试配置:

    • 任务重试次数实例级别失败了整个任务实例重试会更换TaskTracker本次任务实例的Master节点代价较大大型Map/MapReduce慎用。
    • 子任务重试次数Task级别每个子Task失败后单独重试会更换ProcessorTracker本次任务实际执行的Worker节点代价较小推荐使用。
    • 对于单机任务来说假如任务重试次数和子任务重试次数都配置了1且都执行失败实际执行次数会变成4次推荐任务实例重试配置为0子任务重试次数根据实际情况配置。
  • 机器配置用来标明允许执行任务的机器状态避开那些摇摇欲坠的机器0代表无任何限制。

    • 最低CPU核心数填写浮点数CPU可用核心数小于该值的Worker将不会执行该任务。
    • 最低内存GB填写浮点数可用内存小于该值的Worker将不会执行该任务。
    • 最低磁盘GB填写浮点数可用磁盘空间小于该值的Worker将不会执行该任务。
  • 集群配置

    • 执行机器地址指定集群中的某几台机器执行任务debug的好帮手多值英文逗号分割192.168.1.1:27777,192.168.1.2:27777
    • 最大执行机器数量:限定调动执行的机器数量
  • 报警配置:选择任务执行失败后报警通知的对象,需要事先录入。

任务管理

可以方便地查看和管理系统当前录入的任务信息。

任务管理

运行状态

可以方便地查看当前运行的任务实例,点击详情即可获取详细的信息,点击日志可以查看通过omsLogger上报的日志,点击停止则可以强制终止该任务。

运行状态

在线日志

在线日志