工作流任务编排_分布式任务调度(SchedulerX)-阿里云帮助中心

本文介绍如何通过可视化的工作流进行任务编排且支持Cron表达式和API。

使用说明

工作流中的Job没有独立调度时间，跟随工作流的时间开始调度。
工作流调度至少要有2个Job，且有依赖关系。如果只有一个Job，请直接使用任务管理。
工作流支持跨应用编排，可以将不同应用下的任务进行编排。

使用限制

当前只有Java任务支持数据传输，分布式Java任务请使用MapReduce模型进行数据传输。

使用指南

具体操作，请参见流程管理。

工作流上下游数据传递

SchedulerX提供工作流任务编排，同时支持任务上下游的数据传递。

返回执行结果

/**
 *
 * @param status
 * @param result, the size should be less than 1000 bytes
 * @throws Exception
 */
public ProcessResult(boolean status, String result) throws Exception;

在Processor结尾，通过该方法可以返回result执行结果。

说明

result的长度不能超过1000字节，不是String的长度。如果有中文字符，可能会超过1000字节，超过1000字节时任务会失败。

获取上游数据

List<JobInstanceData> upstreamDatas = JobContext.getUpstreamData();

在Processor里，可以通过该接口从JobContext中获取上游的数据，上游的数据是一个list（可能有多个父节点）。JobInstanceData里有两个属性，分别是JobName和Data（String类型）。

Demo

首先编写三个JobProcessor。

public class TestSimpleJobA extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        System.out.println("TestSimpleJobA " + DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
        return new ProcessResult(true, String.valueOf(1));
    }
}

public class TestSimpleJobB extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        System.out.println("TestSimpleJobB " + DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
        return new ProcessResult(true, String.valueOf(2));
    }
}

public class TestSimpleJobC extends JavaProcessor {
    @Override
    public ProcessResult process(JobContext context) throws Exception {
        List<JobInstanceData> upstreamDatas = context.getUpstreamData();
        int sum = 0;
        for (JobInstanceData jobInstanceData : upstreamDatas) {
            System.out.println("jobName=" + jobInstanceData.getJobName() 
            		+ ", data=" + jobInstanceData.getData());
            sum += Integer.valueOf(jobInstanceData.getData());
        }
        System.out.println("TestSimpleJobC sum=" + sum);
        return new ProcessResult(true, String.valueOf(sum));
    }
}

通过控制台配置工作流如下图所示：
触发一次该工作流之后，在左侧导航栏单击执行列表>流程实例列表，找到创建的工作流名称。然后单击实例ID/流程实例图，进入工作流实例详情页面，右键单击JobA的实例，选择详情，进入任务实例详情，可以看到JobA实例结果=1，如下图：
同理，可以看到JobB的实例结果=2， JobC的实例结果=3。

在控制台查看JobC机器的打印信息。

jobName=jobB, data=2
jobName=jobA, data=1
TestSimpleJobC sum=3