spring-batch相关内容
我有一个Spring批处理应用程序,它使用JdbcCursorItemReader从DB表读取数据,并使用FlatFileItemWriter将其写入平面文件。 当我测试我的应用程序时,我看到即使没有通过JdbcCursorItemReader从数据库返回任何数据,FlatFileItemWriter也会创建一个文件。然而,当数据库中没有合适的数据时,我计划使我的工作失败。是否可以这样做,或
..
我查看了链接-https://github.com/spring-projects/spring-batch/blob/master/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/support/ClassifierCompositeItemProcessorTests.java,但没有太多问题。
..
在Spring批处理中,我尝试读取CSV文件,并希望将每行分配给单独的线程并对其进行处理。我已经尝试过使用Task Executor来实现它,如果我没有使用作业参数获取文件名,它是有效的。如果我通过作业参数,因为scope="step"所有线程都在从文件中读取同一行。如果我更改scope="job"会不会解决?如果会,请给出解决的方法?目前,我收到如下错误: 原因:java.lang.Ill
..
我使用Java 8新创建了Sprringboot批处理应用程序,我想为仅带附加说明的SpringBatch表创建一个数据库。 我想我必须创建配置文件,但我不知道如何做。 您可以在下面看到我希望在Java程序中使用注释重现的所有配置:
..
我只有一个基本工作和一个基本步骤。此作业每x秒执行一次(为此,我使用Quartz)。然后在我的config类中也有变量“runStep”。仅当runStep为true时,我应该在哪里添加此属性并运行步骤?
..
到目前为止,我可以通过以下代码连接到Cassandra: import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Session; public static Session connection() { Cluster cluster = Cluster.builder()
..
我正在尝试弄清楚如何使用Spring Batch进行聚合。 例如,我有一个带有名称列表的CSV文件: name John Amy John Ryan 我想要文本文件中的姓名计数: name, count Amy, 1 John, 2 Ryan, 1 根据我从Spring Batch学到的,ETL批处理过程(itemReader->ItemProcessor->ItemWrite
..
我有一个简单的Spring批处理作业-逐行读取文件,对输入字符串执行一些操作,然后编写一些输出。输出文件包含输入的每一行以及该行的一些处理状态(成功/失败)。从//读取文件,并将处理后的输出写入//所有这些值都作为jobParameters传递 文件读取器是这样的:
..
对于Spring批处理作业,我们在同一个表上有两个不同的查询。要求具有执行两个查询以从同一个表中读取数据的读取器。 一种方式可以是:
..
我在没有ItemWriter的情况下定义了我的微线程,如下所示: 我收到以下错误: 配置问题:元素既没有‘Writer’属性,也没有
..
我有一个读取和处理输入文件的作业(=作业)-此作业是使用读取器、编写器、多个处理器、侦听器和异常处理程序定义的,我主要出于向后兼容原因不想更改此作业定义 我要实现另一个作业(=Jobb),该作业按照一定的标准和顺序从目录中读取文件,然后发送要由Joba处理的文件 我正在查看[MultiResourceItemReader][1] [1]:http://docs.spring.io/s
..
我使用Spring Batch&;Quartz读取数据库表并写入另一个表。数据库为Oracle,为C3P0 问题是每个作业都必须有唯一的参数,我尝试了RunIdIncrementer,并且我尝试了此代码: public class JobRerunner implements JobParametersIncrementer { @Override public
..
我的工作很简单,如下所示: it
..
我有一个Spring批处理作业,可能会跨多个服务器运行。我有一个侦听器,可以防止作业的多个实例在一台服务器上同时运行。但是,我希望确保此作业不能在多台服务器上同时运行。 我已搜索,但找不到此问题的解决方案 推荐答案 我实现了一个侦听器,该侦听器检查与某个名称匹配的Spring批处理控制表中正在运行的Job执行的次数。如果执行大小超过1,则当前作业的jobExecution失败。代
..
我想使用Spring-Complex-Task执行我的应用程序,并且我已经构建了执行得非常好的复杂Spring-Batch Flow Job。 您能解释一下弹簧批处理作业和弹簧合成任务有什么不同吗?它们中哪一个最好? 推荐答案 Spring Cloud数据流中的组合任务实际上构建在Spring Batch上,因为任务到任务的转换由动态生成的Spring批处理作业管理。此模型允许将批处
..
下面是将在作业中初始化的步骤代码。 @Bean public Step stepOne() { return stepBuilderFactory.get("stepOne") . chunk(1) .reader(readerOne()) .processor
..
我正在研究使用Spring Batch来处理编码压缩文件中的记录。这些记录是可变长度的,其中编码了嵌套的可变长度数据字段。 我是Spring和Spring Batch的新手,这就是我计划如何构建批处理配置。 ItemReader需要将压缩(*.gz)文件输入流中的单个记录读取到POJO(字节数组)中,此记录的长度将包含在流的前两个字节中。 ItemProcessor将解码字节数组,并
..
我正在尝试使用Spring Batch读取带有日期的CSV文件,但在将日期解析为LocalDateTime对象时遇到问题: 字段‘Date’上对象‘target’中的字段错误:拒绝值[2017-07-20 04:15:25.0];代码[typeMismatch.target.date,typeMismatch.date,typeMismatch.java.time.LocalDateTime
..
我正在使用SpringBatch 2.1.7版本的核心和基础结构JAR读取CSV文件并将其保存到数据库。 将我的代码与Spring Quartz调度程序集成以每分钟运行一次,批处理的读写工作正常,但失败,错误为“org.springframework.dao.OptimisticLockingFailureException:尝试用错误的版本(2)更新步骤执行id=1,其中当前版本为1”
..
我有以下Spring批处理作业配置: @Configuration @EnableBatchProcessing public class JobConfig { @Autowired private JobBuilderFactory jobBuilderFactory; @Autowired private StepBuilderFactory ste
..