spring-batch相关内容

Spring Batch-当ItemReader没有返回数据时如何使作业失败

我有一个Spring批处理应用程序,它使用JdbcCursorItemReader从DB表读取数据,并使用FlatFileItemWriter将其写入平面文件。 当我测试我的应用程序时,我看到即使没有通过JdbcCursorItemReader从数据库返回任何数据,FlatFileItemWriter也会创建一个文件。然而,当数据库中没有合适的数据时,我计划使我的工作失败。是否可以这样做,或 ..
发布时间:2022-02-28 16:38:52 其他开发

春批多线程文件读取

在Spring批处理中,我尝试读取CSV文件,并希望将每行分配给单独的线程并对其进行处理。我已经尝试过使用Task Executor来实现它,如果我没有使用作业参数获取文件名,它是有效的。如果我通过作业参数,因为scope="step"所有线程都在从文件中读取同一行。如果我更改scope="job"会不会解决?如果会,请给出解决的方法?目前,我收到如下错误: 原因:java.lang.Ill ..
发布时间:2022-02-28 16:35:28 其他开发

为Spring Batch应用初始化H2数据库

我使用Java 8新创建了Sprringboot批处理应用程序,我想为仅带附加说明的SpringBatch表创建一个数据库。 我想我必须创建配置文件,但我不知道如何做。 您可以在下面看到我希望在Java程序中使用注释重现的所有配置: ..
发布时间:2022-02-28 16:33:33 Java开发

条件为假时如何跳过批处理步骤

我只有一个基本工作和一个基本步骤。此作业每x秒执行一次(为此,我使用Quartz)。然后在我的config类中也有变量“runStep”。仅当runStep为true时,我应该在哪里添加此属性并运行步骤? ..
发布时间:2022-02-28 16:31:39 其他开发

如何对Spring Batch进行聚合?

我正在尝试弄清楚如何使用Spring Batch进行聚合。 例如,我有一个带有名称列表的CSV文件: name John Amy John Ryan 我想要文本文件中的姓名计数: name, count Amy, 1 John, 2 Ryan, 1 根据我从Spring Batch学到的,ETL批处理过程(itemReader->ItemProcessor->ItemWrite ..
发布时间:2022-02-28 16:28:59 其他开发

在Spring-Batch中使用FlatFileItemWriter创建新的输出文件

我有一个简单的Spring批处理作业-逐行读取文件,对输入字符串执行一些操作,然后编写一些输出。输出文件包含输入的每一行以及该行的一些处理状态(成功/失败)。从//读取文件,并将处理后的输出写入//所有这些值都作为jobParameters传递 文件读取器是这样的: ..
发布时间:2022-02-28 16:27:36 其他开发

在Spring Batch中从处理器调用另一个作业

我有一个读取和处理输入文件的作业(=作业)-此作业是使用读取器、编写器、多个处理器、侦听器和异常处理程序定义的,我主要出于向后兼容原因不想更改此作业定义 我要实现另一个作业(=Jobb),该作业按照一定的标准和顺序从目录中读取文件,然后发送要由Joba处理的文件 我正在查看[MultiResourceItemReader][1] [1]:http://docs.spring.io/s ..
发布时间:2022-02-28 16:22:45 Java开发

Spring Batch限制跨多个服务器的单个作业实例

我有一个Spring批处理作业,可能会跨多个服务器运行。我有一个侦听器,可以防止作业的多个实例在一台服务器上同时运行。但是,我希望确保此作业不能在多台服务器上同时运行。 我已搜索,但找不到此问题的解决方案 推荐答案 我实现了一个侦听器,该侦听器检查与某个名称匹配的Spring批处理控制表中正在运行的Job执行的次数。如果执行大小超过1,则当前作业的jobExecution失败。代 ..
发布时间:2022-02-28 16:18:12 Java开发

Spring Batch Flow作业与Spring组合任务

我想使用Spring-Complex-Task执行我的应用程序,并且我已经构建了执行得非常好的复杂Spring-Batch Flow Job。 您能解释一下弹簧批处理作业和弹簧合成任务有什么不同吗?它们中哪一个最好? 推荐答案 Spring Cloud数据流中的组合任务实际上构建在Spring Batch上,因为任务到任务的转换由动态生成的Spring批处理作业管理。此模型允许将批处 ..
发布时间:2022-02-28 16:17:04 其他开发

Spring Batch处理编码的压缩文件

我正在研究使用Spring Batch来处理编码压缩文件中的记录。这些记录是可变长度的,其中编码了嵌套的可变长度数据字段。 我是Spring和Spring Batch的新手,这就是我计划如何构建批处理配置。 ItemReader需要将压缩(*.gz)文件输入流中的单个记录读取到POJO(字节数组)中,此记录的长度将包含在流的前两个字节中。 ItemProcessor将解码字节数组,并 ..
发布时间:2022-02-28 16:14:00 其他开发

尝试使用错误的版本(2)更新步骤执行id=1,其中当前版本为1

我正在使用SpringBatch 2.1.7版本的核心和基础结构JAR读取CSV文件并将其保存到数据库。 将我的代码与Spring Quartz调度程序集成以每分钟运行一次,批处理的读写工作正常,但失败,错误为“org.springframework.dao.OptimisticLockingFailureException:尝试用错误的版本(2)更新步骤执行id=1,其中当前版本为1” ..
发布时间:2022-02-28 16:10:22 其他开发