Spring Cloud Data Flow 数据源覆盖 Spring Batch 应用程序数据源

Question

我正在设置 Spring Cloud Data Flow 的一个实例。我运行了以下命令：

java -jar spring-cloud-dataflow-server-2.9.2.jar \
--spring.cloud.dataflow.features.streams-enabled=false \
--spring.cloud.dataflow.features.schedules-enabled=true \
--spring.datasource.url=jdbc:postgresql://localhost:5432/batch \
--spring.datasource.username=postgres \
--spring.datasource.password=postgres \
--spring.datasource.driver-class-name=org.postgresql.Driver \
--spring.datasource.initialization_mode=always

我已经使用 Spring Batch 开发了一个批处理作业，并将其部署到该平台中。该作业使用两个数据源：用于 Spring 的批处理和用于我的业务逻辑的任务元数据和 app_db。当我在本地运行该应用程序时，它会按预期批量保存元数据并将我的业务数据保存在 app_db 中。问题是当我尝试在 Spring Cloud Dataflow 内执行 de job 时。该平台覆盖我配置的业务逻辑数据库并仅使用批处理数据库，该数据库应该仅存储元数据。

application.yaml

spring:
  batch:
    datasource:
      url: jdbc:postgresql://localhost:5432/batch
      username: postgres
      password: postgres

  datasource:
    url: jdbc:postgresql://localhost:5432/app_db
    username: postgres
    password: postgres

DatasourceConfiguration

public class DatasourceConfiguration {
    @Bean
    @ConfigurationProperties("spring.datasource")
    @Primary
    public DataSourceProperties dataSourceProperties() {
        return new DataSourceProperties();
    }
 
    @Bean
    @Primary
    public DataSource dataSource(DataSourceProperties dataSourceProperties) {
        return dataSourceProperties.initializeDataSourceBuilder().build();
    }

    @Bean(name = "batchDataSourceProperties")
    @ConfigurationProperties("spring.batch.datasource")
    public DataSourceProperties batchDataSourceProperties() {
        return new BatchDataSourceProperties();
    }
    
    @Bean(name = "batchDataSource")
    public DataSource batchDataSource() {
        return batchDataSourceProperties.initializeDataSourceBuilder().build();
    }
}

@SpringBootApplication
@EnableTask
@EnableBatchProcessing
public class BatchApplication {

    @Bean
    public TaskConfigurer taskConfigurer(@Qualifier("batchDataSource") DataSource dataSource) {
        return new DefaultTaskConfigurer(dataSource);
    }

    @Bean
    public BatchConfigurer batchConfigurer(@Qualifier("batchDataSource") DataSource dataSource) {
        return new DefaultBatchConfigurer(dataSource);
    }
    public static void main(String[] args) {
        SpringApplication.run(BatchApplication.class, args);
    }
}

Job

@Bean
public Job startJob(JobBuilderFactory jobBuilderFactory, DataSource dataSource) {
    try {                                   
        System.out.println(dataSource.getConnection().getMetaData().getURL().toString());
        } catch (Exception e) {
          //TODO: handle exception
        }
}

当我查看数据源时，从本地执行批处理时将打印jdbc:postgresql://localhost:5432/app_db，并且jdbc:postgresql://当从 SCDF 执行批处理（任务）时，将打印 /localhost:5432/batch 。

我想知道数据流如何覆盖应用程序 spring.datasource 即使我在执行任务时没有传递任何参数。请提出一个解决方案以避免覆盖数据源。 我正在考虑的一种解决方案是创建 AppDatasourceConfiguration(app.datasource) 使用它。但是是否有可能使用 spring.datasource 而不会被 SCDF 覆盖。