在 Spring-cloud-dataflow 复合任务之间传递参数
Passing parameters between Spring-cloud-dataflow composite task
我在 spring-cloud-dataflow 中构建了一个复合任务。
正在运行。
现在我需要将第一个任务 (FirstCloudTask) 的输出传递给第二个任务 (SUCCESS_TASK)。
如何在完成第一个任务后将输入参数传递给我的发送任务?例如:job_id、job_name 等,从第一个任务到第二个任务。
这是我的复合任务 DSL
FirstCloudTask 'FAILED'->FAILED_TASK && SUCCESS_TASK
任务应用程序旨在独立运行。
尽管 SCDF 提供了一种机制(即组合任务)来编排独立任务 运行 作为有向图,但是没有机制在图中包含的任务之间共享或传播信息。换句话说,没有开箱即用的意见来解决这个需求。
在实践中,我们看到人们依赖外部系统(例如数据库或消息代理)在任务之间共享信息。
我在 spring-cloud-dataflow 中构建了一个复合任务。
正在运行。
现在我需要将第一个任务 (FirstCloudTask) 的输出传递给第二个任务 (SUCCESS_TASK)。
如何在完成第一个任务后将输入参数传递给我的发送任务?例如:job_id、job_name 等,从第一个任务到第二个任务。
这是我的复合任务 DSL
FirstCloudTask 'FAILED'->FAILED_TASK && SUCCESS_TASK
任务应用程序旨在独立运行。
尽管 SCDF 提供了一种机制(即组合任务)来编排独立任务 运行 作为有向图,但是没有机制在图中包含的任务之间共享或传播信息。换句话说,没有开箱即用的意见来解决这个需求。
在实践中,我们看到人们依赖外部系统(例如数据库或消息代理)在任务之间共享信息。