spring-batch相关内容

如何在ItemProcessor或ItemWriter中获取Spring Batch Job ContextId?

我需要将Job ExecutionId存储为Entity的字段之一。(我正在使用JpaItemWriter) 这里的一个主题解释从StepExcecution,我可以得到StepContext->JobExecution。在这种情况下,如何获取StepExecution? (我不需要将任何数据从一个步骤传递到另一个步骤,我只需要JobExecuionId) 谢谢您的帮助, 穆内尔·艾哈 ..
发布时间:2022-02-28 15:09:03 其他开发

Spring Cloud任务和Spring Batch的区别是什么?

我检查了Introducing Spring Cloud Task,但以下问题不清楚。 我使用的是Spring Batch 当我们已经有Spring Batch提供的元数据时,Spring Cloud Task有什么用? 我们计划使用Spring Cloud数据流来监控Spring批量。所有批处理作业都可以作为任务导入到SCDF中,并且可以在那里进行调度,但是看不到对MongoD ..
发布时间:2022-02-28 15:07:19 其他开发

春季批次-跳过流程记录

我想跳过进程中的某些记录。 我尝试的是,我创建了自定义异常,并在想要跳过记录时引发异常,它调用SkipInProcess方法上的Skip侦听器。它工作正常。 请查找配置。 ..
发布时间:2022-02-28 15:06:02 其他开发

PageSize和Commit-Interval之间的Spring批处理差异

Spring-Batch Reader“pageSize”属性和Writer“Commit-Interval”之间有什么关系/区别。 我可能是错的,但是我在我的应用程序中看到了这样一种模式,即每超过一个页面大小,我就会看到一个提交。这是真的吗? 谢谢 推荐答案 commit-interval定义在单个块中处理多少项。在单个事务的范围内读取、处理和写入该数量的项目(不支持跳过/重 ..
发布时间:2022-02-28 15:04:48 其他开发

不同模式中的Spring-Batch元数据表

我的应用程序中有一个连接到Oracle数据库的数据源。是否可以通过此数据源访问包含Spring-Batch元数据表的另一个模式?此数据源的用户有权访问其他架构。 我已经尝试过JobRepository的“tablePrefix”属性,例如“Schema.Batch_”。但它不起作用。简而言之,我搜索告诉Spring-Batch访问类似于“SELECT.FROM Schema.Batch_.. ..
发布时间:2022-02-28 15:02:13 其他开发

Spring Batch:重新启动一个作业,然后自动启动下一个作业

我需要创建恢复模式。 在我的模式中,我只能在给定的时间窗口启动作业。 如果作业失败,它将仅在下一个时间窗口重新启动,完成后,我希望启动为此窗口预先计划的计划作业。 作业之间唯一的区别是时间窗口参数。 我考虑将JobExecutionDecider与JobExplorer结合使用,或者覆盖Joblauncher。但这一切似乎都太具侵扰性了。 我找不到符合我需要的示例,任何想法都将是最受欢 ..
发布时间:2022-02-28 14:59:05 其他开发

如何设置在flatfileItemReader中读取的最大记录数?

我的应用程序只需要读取固定数量的记录 已处理(&A)。如果我使用的是flatfileItemReader,如何限制这一点? 在基于DB的Item Reader中,当达到max_Limit时,我返回NULL/空列表。 如果我使用的是org.springframework.batch.item.file.FlatFileItemReader,如何实现同样的目标? 推荐答案 对于FlatFi ..
发布时间:2022-02-28 14:57:39 其他开发

如何将@Lazy之类的内容应用到Spring Batch?

我有一个具有多个作业(作业A、作业B、作业C等)的Spring Batch项目。当我运行特定的作业A时,我得到了作业A的日志,显示作业B、C、.也被创造出来了。是否有办法避免在启动作业A时创建其他Bean。 我已尝试使用@Lazy批注,但似乎不起作用。 @Configuration @EnableBatchProcessing public class BatchConfigurati ..
发布时间:2022-02-28 14:55:54 其他开发

使用@StepScope时Spring Batch重启功能不起作用

我希望使用Spring Batch(v3.0.9)重新启动功能,以便在JobInstance重新启动时,流程步骤从最后一个失败的块点开始向前读取。只要我不对myBatisPagingItemReaderbean方法使用@StepScope注释,我的重启就可以正常工作。 我使用@StepScope以便可以进行后期绑定,以便在我的myBatisPagingItemReaderbean方法@Value ..
发布时间:2022-02-28 14:53:07 其他开发

使用Spring Batch写入不同的数据源

对于一个项目,我需要处理一个表中的项,并为3个不同的表生成3个不同的项,所有3个项都位于与第一个项不同的第二个数据源中。该实现是使用Oracle DB上的Spring Batch完成的。我认为这个question与我需要的内容类似,但它在末尾只写了一项不同的内容。 要消除这种情况,请执行以下操作: DataSource 1 D ..
发布时间:2022-02-28 14:52:05 其他开发

使项读取器返回列表,而不是单个对象-Spring Batch

问题是:如何让Spring Batch中的项阅读器传递列表,而不是单个对象。 我已经搜索过了,一些答案是修改项目读取器以返回对象列表,并将项目处理器更改为接受列表作为输入。 如何做项目阅读器/编写项目阅读器代码? 推荐答案 查看official spring batch documentation for itemReader public interface Ite ..
发布时间:2022-02-28 14:48:29 其他开发

如何在出现异常的情况下重写委托编写器的Spring Batch CompositeItemWriter管理事务?

我在此扩展此How does Spring Batch CompositeItemWriter manage transaction for delegate writers?问题: 在我的示例中,我有一个下面的CompositeItemWriter,它将数据写入同一数据库的多个表中,在写入数据之前,它通过实现各种业务规则来转换数据。在这里,一条记录可能满足不同的业务规则等。因此,一个写入者可能 ..
发布时间:2022-02-28 14:45:15 其他开发

Spring Batch中的跳转是如何实现的?

我想知道如何在我的ItemWriter中确定Spring Batch当前是处于块处理模式还是处于后备单项处理模式。首先,我没有找到这个后备机制是如何实现的信息。 即使我还没有找到我的实际问题的解决方案,我也愿意与您分享我关于后备机制的知识。 如果我遗漏了任何内容,请随时添加带有附加信息的答案;-) 推荐答案 跳过机制的实现可以在FaultTolerantChunkProce ..
发布时间:2022-02-28 14:43:50 其他开发

如何处理SpringBatch中ItemReader之后的逻辑相关行?

方案 为简单起见,假设我有一个返回25行的ItemReader。 前10行属于学生A 接下来的5个属于学生B 和剩下的10个属于学生C 我想逻辑地将它们聚合在一起,比如说按StudentId,然后将它们展平,以结束每个学生一行。 问题 如果我理解正确,将提交间隔设置为5将执行以下操作: 向处理器发送5行(它将聚合这些行或执行我告诉它的任何业务逻辑)。 ..
发布时间:2022-02-28 14:40:08 其他开发

根据物料的属性作为条件,将数据路由到物料写入器中的多个文件

我在阅读器中收到一份项目列表。 在每个Item对象中都有一个名为Code的属性,它有几个我事先不知道的可能值。 1)根据每个项目中Code的值,我希望将该特定项目写入与该Code相关的输出文件中。例如,如果我当前项目的Code是“abc”,则应将该项目写入编写器中的abc.txt。 2)如果当前项中存在Code“xyz”,而该文件不存在,则应该创建一个新文件,并且该项应该转到该文件。 3) ..
发布时间:2022-02-28 14:38:33 其他开发