spring-batch

0热度

2回答

Spring批处理 - ItemWriter - DataIntegrityViolationException - 跳过记录 - 重试 - 不能正常工作

我一直在困扰着这个问题。我使用弹簧分批3.0.7 问题是在org.springframework.dao.DataIntegrityViolationException情况下在ItemWriter一个记录，在组块的记录剩余部分（块大小= 10）是即使在提供skipPolicy之后也不会插入数据库（对于所有例外都返回true）。我的理解是，如果在提交整个块时会有任何异常（通过skipPoli

0热度

1回答

如何从文件读取器传递文件名到文件写入器弹簧批次

我正在从文件夹中读取多个文件。假设文件名像test1.txt，test2.txt，test3.txt。我想将这些文件名传递给writer，并生成输出文件名，如'test1.xml''test2.xml''test3.xml。欣赏这方面的任何帮助。 @Autowired public StepBuilderFactory stepBuilderFactory; @Autowired pub

0热度

1回答

如何防止ListenerExecutionFailedException：监听器抛出异常

我需要做些什么来防止RabbitMQ推测的以下异常。 org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception at org.springframework.amqp.rabbit.listener.AbstractMessag

0热度

1回答

在Spring批处理中排队作业实例

我们在每个工作日的Spring批处理中都有一个作业，由另一个系统触发。有时在同一天有几个工作实例要运行。每个人都从另一个系统触发。每个作业运行约一个小时，如果有多个作业实例要运行，我们会遇到一些数据问题。我们希望如下优化此步骤，如果没有作业实例正在运行，那么启动一个新的作业实例，如果有作业实例正在运行已经将新的作业放入队列中。每个作业实例必须在下一个作业触发前完成。如果一个人失败，下一个人必须

0热度

1回答

在spring批处理中，如何将参数从ItemWriter传递给SkipListener？

在我的spring批处理作业中，如果在itemWriter写入发生错误时，它会被跳过。 ItemSkipListener收到它并将项目记录到文件。我的项目有一个列表数据，我想知道列表中出现错误的元素。但是在ItemSkipListener中，我只能知道item和throwable。（无法知道列表中的元素）所以我认为itemWriter将ItemSkipListener的列表索引传递给Ite

0热度

1回答

Spring Batch的：动态复合读写器/处理器/作家

我见过this (2010)和this (SO, 2012)，但还是没有得到我需要的答案... 是否有Spring Batch的一个选项，有一个动态的复合读写器/处理器/写入器？这个想法是有能力在运行时替换处理器，并且在多处理器（AKA复合处理器）的情况下，可以选择添加/删除/替换/改变处理器的顺序。如前所述，读者/作者也是如此。我想到了像从数据库中读取处理器列表（使用缓存？），并且可以更改项

0热度

1回答

春季整合sftp：如何手动触发下载操作并在下载完成后执行其他操作？

我在我的项目中使用了spring批处理+ spring集成sftp。我不想在应用程序启动时触发下载。我想下载过程中的第一步被触发，继续第二步所有的文件后下载到本地，不知道howt以实施

0热度

1回答

春季集成：连接多台sftp服务器的解决方案/技巧？

我的spring批处理项目需要从多个sftp服务器下载文件。 sftp主机/端口/文件路径配置在application.properties文件中。我考虑使用Spring集成的'ftp out-bound gateway'来连接这些服务器并下载文件。但我不知道如何做这种配置（我使用java配置，）并使其工作？我想我需要一些方法来定义多个会话工厂根据在application.properties文件

1热度

2回答

春季计划任务和春季批处理作业之间有什么区别

我不明白计划任务和批处理作业之间的区别。通过计划任务我的意思是被配置像这样的那些： @EnableScheduling public class AppConfig{ .. 和像 @Scheduled(fixedRate=550) public void doSomething(){ .. 使用批处理作业我的意思是这些： @EnableBatchProcessing publi

0热度

2回答

Java 8并行流和弹簧批处理之间的比较

我有一个队列，其中某些其他应用程序将放置消息，而我的应用程序所做的只是轮询队列并获取所有消息并转换为其他对象并保留在数据库中。因此，我有两种方法来处理这个问题。1.）使用spring scheduler并每隔5秒轮询所有消息，然后使用java 8的并行流来保存数据库，因为所有流都是独立的。 2.）有人建议使用spring批处理，但运气不好，对于使用spring批处理没有足够的解释。你可以请一些