spring-batch相关内容

java - 如何为spring批处理数据和业务数据配置单独的数据源?我应该这样做吗?

我的主要工作只做读取操作,另一个做一些写操作,但是在忽略事务的 MyISAM 引擎 上,所以我不需要一定的事务支持.如何配置 Spring Batch 以拥有自己的 JobRepository 数据源,与保存业务数据的数据源分开?最初的一个数据源配置是这样完成的: @Configuration公共类 StandaloneInfrastructureConfiguration {@自动连线环境环境 ..
发布时间:2021-12-03 18:02:31 其他开发

Spring-Batch 没有将元数据持久化到数据库?

我想创建一个 spring-batch 作业,但我想在没有任何数据库持久性的情况下运行它.不幸的是,spring-batch 需要以某种方式将 metadata ob 作业周期写入数据库,从而促使我至少提供某种带有事务管理器和实体管理器的数据库. 是否可以阻止元数据并独立于 txmanagers 和数据库运行? 更新: ERROR org.springframework.batch. ..
发布时间:2021-11-25 20:38:47 Java Web开发

Spring Batch 中多个数据源的使用

我正在尝试在 Spring Batch 中配置几个数据源.启动时,Spring Batch 抛出以下异常: 要使用默认的 BatchConfigurer,上下文必须包含不超过一个 DataSource,找到 2 批量配置的片段 @Configuration@EnableBatchProcessing公共类 BatchJobConfiguration {@基本的@Bean(name = ..
发布时间:2021-11-25 20:03:18 Java Web开发

我们可以有后台批处理的微服务架构吗?

最近我开发了一个 spring 批处理应用程序,其中配置了 3 个作业.只需部署一个 jar 即可完成三个 3 工作. 如果我们有另一个业务需求,我很乐意在现有配置中添加一个新作业,它会正常工作.我们不会为此作业创建单独的 jar. 我正在学习一些微服务教程.我注意到我们为每个微服务创建了单独的代码存储库.在 Spring Batch 中,我们将所有作业添加到一个 jar 中,尽管它们 ..
发布时间:2021-11-17 03:10:12 其他开发

如果在读取消息过程中发生任何异常,如何管理弹簧批处理作业中使用的 KafkaItemReader 中的偏移量

我第一次在开发基于 Kafka 的 Spring Boot 应用程序.我的要求是使用 spring 批处理创建一个包含所有记录的输出文件.我创建了一个 spring 批处理作业,其中集成了一个扩展 KafkaItemReader 的自定义类.我现在不想提交偏移量,因为我可能需要返回从已经消耗的偏移量中读取一些记录.我的消费者配置有这些属性; enable.auto.commit: 假自动偏移 ..
发布时间:2021-11-12 03:13:42 其他开发

如果在读取消息过程中发生任何异常,如何管理弹簧批处理作业中使用的 KafkaItemReader 中的偏移量

我第一次在开发基于 Kafka 的 Spring Boot 应用程序.我的要求是使用 spring 批处理创建一个包含所有记录的输出文件.我创建了一个 spring 批处理作业,其中集成了一个扩展 KafkaItemReader 的自定义类.我现在不想提交偏移量,因为我可能需要返回从已经消耗的偏移量中读取一些记录.我的消费者配置有这些属性; enable.auto.commit: 假自动偏移 ..
发布时间:2021-11-12 03:12:58 其他开发

卡夫卡&Spring Batch - 如何仅读取来自同一主题的未提交消息?

我正在使用 Spring 批处理和 Kafka 进行小批量工作,它从 Kafka 主题读取 json 数据,将其转换为 Student 对象,更改一个值并将其发送回 Kafka 主题.一切正常,但我唯一的问题是我的消费者总是从主题的乞求中阅读.我需要它从最后一条未消费的消息中读取.我已经添加了这些属性: ConsumerConfig.AUTO_OFFSET_RESET_CONFIG 到最早Con ..
发布时间:2021-11-12 02:40:09 其他开发

Spring 批处理 2.2 JavaConfig

我正在尝试让 Spring Batch 2.2 与 JavaConfig 一起工作. 现在他们有一个 @EnableBatchProcessing 注释来设置很多东西.默认该注解为其作业数据使用数据源,但我们不想保存此数据,也不想为其创建表.该文档说明了有关自定义的内容,但我无法使其正常工作: 用户必须提供一个 DataSource 作为上下文中的 bean,或者在配置类本身中实现 ​ ..
发布时间:2021-11-10 23:14:03 其他开发

Spring批处理:组装作业而不是配置它(可扩展作业配置)

背景 我正在设计一个可以读取分隔文件并将其加载到List 的文件读取层.我决定使用 Spring Batch,因为它提供了许多可扩展性选项,我可以根据文件的大小将其用于不同的文件集. 要求 我想设计一个可用于读取任何分隔文件的通用作业 API. 应该有一个单独的 Job 结构用于解析每个带分隔符的文件.例如,如果系统需要读取 5 个文件,则会有 5 个作业(每个文件一个).这 ..
发布时间:2021-11-10 22:49:59 其他开发

在无限循环中运行的 Spring Batch 作业

我正在处理简单的 Spring Batch 作业.当我启动工作时,它会在无限循环中运行.它不会停止.根据我的调度程序时间,它应该每 10 秒运行一次.但是当工作开始时,它不会停止.它只是分别从读取器、处理器和写入器打印系统输出.我正在与读者、处理器和作家一起创造工作.我正在通过注释进行所有配置.不是通过 xml. 这里是批量配置 @Configuration@EnableBatchProc ..
发布时间:2021-11-10 22:47:35 其他开发

我想将excel转换为xml

我想将excel转换为xml.谁能告诉我如何使用mapper?我的代码: 公共类WorkGroupReader实现ItemReader>{WorkGroupMapper 线映射器;public void setLinemapper(WorkGroupMapper linemapper) {this.linemapper = linemapper;}@覆盖公共列表read() 抛出异常、Unexp ..
发布时间:2021-10-02 18:47:28 其他开发

Spring Batch CommandLineJobRunner 找不到 .xml 配置文件

我是 Spring Batch Framework 的初学者,我从 http://www.javabeat.net/introduction-to-spring-batch/ 用作学习工具.我在 Eclipse 中设置了我的项目,类似于页面中的代码,它看起来像这样: 代码使用 CommandLineJobRunner 执行 fileWritingJob.xml 中的作业,如下所示: pac ..
发布时间:2021-10-01 20:19:29 其他开发

Spring Batch - FlatFileParseException(用双引号记录)

字段值之间的双引号记录很少. 所以当我使用 FlatFileItemReader 时,它会为这些记录抛出 FlatFileParseException. 样本记录是: 7^A3989815^A2400284298^ABU^AA" - CLEANING INC.^A$ 我们如何在 Spring Batch Item Readers 中处理此类记录? 问候,香卡 解决方案 ..
发布时间:2021-10-01 20:00:14 其他开发