配置Spring Cloud Task
现在我们需要将我们的Spring Batch作业与Spring Cloud Task集成。为此,我们需要在application.properties文件中添加以下属性:
代码语言:javascript复制spring.cloud.task.closecontext_enabled=false
spring.cloud.task.name=batch-task
spring.cloud.task.initialize.enable=true
这些属性将指定Spring Cloud Task的配置,包括禁用任务完成后关闭应用程序上下文、指定任务名称和启用任务初始化。
测试
现在我们已经完成了Spring Cloud Task和Spring Batch的集成,现在我们可以测试它是否正常工作。为此,我们可以使用Spring Cloud Data Flow或直接使用Spring Cloud Task的命令行工具。
6.1 使用Spring Cloud Data Flow测试
要使用Spring Cloud Data Flow,请执行以下步骤:
- 安装Spring Cloud Data Flow Server
- 使用Spring Cloud Data Flow UI或Shell创建任务定义,如下所示:
task create batch-task --definition "taskapp:1.0-SNAPSHOT --spring.profiles.active=cloud"
启动任务定义,如下所示:
代码语言:javascript复制task launch batch-task
查看任务执行结果,如下所示:
代码语言:javascript复制task execution list
task execution view --id <task-execution-id>
6.2 使用Spring Cloud Task命令行工具测试
要使用Spring Cloud Task命令行工具,请执行以下步骤:
- 安装Spring Cloud CLI
- 使用命令行工具创建任务定义,如下所示:
spring cloud task create --name batch-task --definition "taskapp:1.0-SNAPSHOT --spring.profiles.active=cloud"
启动任务定义,如下所示:
代码语言:javascript复制spring cloud task launch --name batch-task
查看任务执行结果,如下所示:
代码语言:javascript复制spring cloud task execution list
spring cloud task execution view --id <task-execution-id>
在查看任务执行结果时,您应该能够看到Spring Batch作业的执行情况,包括启动时间、结束时间、执行状态等。