自定义工作任务节点

自定义任务节点通常称为算子节点，是 Taskflow 中最基础的任务类型，用于执行自定义业务逻辑。这些算子节点由外部系统服务来执行具体的业务逻辑处理。 开发者通过平台提供的 SDK 即可快速将系统中的任意函数发布作为算子节点发布到平台，通过编排引擎工具按业务场景进行流程编排，最后发布到调度引擎进行执行。

通过一个示例快速体验将程序中的一个函数发布到工作流

Java 示例程序 (国内)
Java 示例程序 (海外)

快速集成

Maven 工程依赖

<dependency>
    <groupId>cn.taskflow</groupId>
    <artifactId>taskflow-sdk</artifactId>
    <version>${最新版本}</version>
</dependency>

Gradle 工程依赖

cn.taskflow:taskflow-sdk:$最新版本

创建开发者应用

https://console.taskflow.cn/application-manager 创建开发者应用

程序文件 config.properties

#开发者应用key
taskflow.key-id=您的开发者应用Key
#开发者应用秘钥
taskflow.key-secret=您的开发者秘钥

演示将一个函数发布到平台

public class MyWorker {
    /**
     * 加法方法
     * @param a 第一个整数
     * @param b 第二个整数
     * @return 两个整数相加的结果
     */
    @WorkerTask(value = "add", tag = "加法计算", description = "演示简单的加法计算 ( a + b = ? )")
    public int add(@InputParam("a") int a, @InputParam("b") int b) {
        return a + b;
    }
}

创建客户端

    TaskflowConfig config = new PropertiesReader("config.properties").toConfig();
    ApiClient client = new ApiClient(config);
    client.addWorker(new MyWorker());
    client.start();

任务输出

任务完成后，工作器可以返回任意 JSON 格式的输出数据，这些数据可以在后续任务中通过表达式：${task_name_ref.output} 引用。