【发布时间】：2019-10-17 06:38:20
【问题描述】：
我们的应用程序是使用 Spring boot + Gradle 构建的。我们有一个新的要求来实现 spring 批处理作业，它将使用 autosys（作业调度工具）触发，它有 3 个步骤执行 3 种不同的操作（文件准备、ftp 和审计操作）。我附上了@EnableBatchProcessing 配置文件供您参考。这是我与 Spring Cloud Data Flow 相关的问题。
- Spring 云数据流项目可以用 Gradle 搭建吗？我看到所有使用 Maven 构建的示例项目，并且 Spring 官方页面说 Maven 是 Spring Cloud Data Flow 必须的。 Gradle 是我们公司唯一获批的构建项目。
- 我们正在寻找 Spring Cloud 数据流中的 Spring 批处理管理 UI 类型的功能或操作。我可以知道如何在 Spring Cloud 数据流中配置作业吗？任何示例项目？
- 我们的应用程序被部署到 PCF（Pivotal Cloud Foundry）容器中。所以问题是，我们是否需要在 PCF 基础架构中添加任何服务/插件/空间来支持 Spring Cloud 数据流？...
- Spring Cloud 数据流项目生产准备好了吗？这可以在生产中使用吗？
@Configuration
@EnableBatchProcessing
public class TaskletsConfig {
@Autowired
private JobBuilderFactory jobs;
@Autowired
private StepBuilderFactory steps;
@Bean
protected Step flatFilePreparation() {
return steps
.get("flatFilePreparation")
.tasklet(new FlatFilePreparation())
.build();
}
@Bean
protected Step ftpFile() {
return steps
.get("ftpFile")
.tasklet(new FtpFile())
.build();
}
@Bean
protected Step auditFilePreparation() {
return steps
.get("auditFilePreparation")
.tasklet(new AuditFilePreparation())
.build();
}
@Bean
protected Step errorStep() {
return steps
.get("errorStep")
.tasklet(new ErrorStep())
.build();
}
@Bean
public Job job() {
return jobs.get("psbijob").start(flatFilePreparation()).on(ExitStatus.FAILED.getExitCode()).to(errorStep())
.from(flatFilePreparation()).on("*").to(ftpFile()).on(ExitStatus.FAILED.getExitCode()).to(errorStep())
.from(ftpFile()).on("*").to(auditFilePreparation()).end().build();
}
@Bean
public JobRepository jobRepository() throws Exception {
MapJobRepositoryFactoryBean factory
= new MapJobRepositoryFactoryBean();
factory.setTransactionManager(transactionManager());
return (JobRepository) factory.getObject();
}
@Bean
public PlatformTransactionManager transactionManager() {
return new ResourcelessTransactionManager();
}
@Bean
public JobLauncher jobLauncher() throws Exception {
SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
jobLauncher.setJobRepository(jobRepository());
return jobLauncher;
}
}
【问题讨论】：
标签： spring spring-cloud-dataflow spring-batch-admin