spring-batch

0热度

1回答

我已经用spring批处理建立了一个java批处理项目，该批处理项目允许将CSV的行保存在数据库的表中。我想知道是否有可能用Spring API REST通过POST方法触发批处理，这会加入必要的CSV。预先感谢您

-2热度

1回答

public interface JobLauncher { public JobExecution run(Job job, JobParameters jp) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInv

1热度

2回答

将当前时间戳记作为作业参数弹簧批次

我正在使用弹簧批次，但由于作业实例已存在错误，我需要在我的作业参数中添加当前时间。我无法找出其中添加工作paramters。这里是我的代码： <step id="myStep"> <tasklet> <chunk reader="myReader" processor="myProcessor" writer="myWriter" commit-interval="6000" skip

1热度

1回答

Spring Batch的复杂的自定义ItemReader

我新手在春季批次，我不能确定的是什么模式的读者，我需要使用。我需要创建类WSRequestClass并将其发送到SOAP Web服务。 public class WSRequestClass{ private String data1; private String data2; private String data3; private String da

-1热度

1回答

读取平面文件并写入多个写入器，写入不同的对象

我有一个读取平面文件并创建一个TRADE java对象的需求。现在处理器应该创建3个基于TRADE java对象的不同java对象。我必须将这3个不同的java对象写入3个不同的xml文件。简单地说，我想要一个读取3个处理器，并根据读取的数据写入多个xml文件。我试图compositeItemWriter但它会采取同样的对象writing.but我有3个不同的对象的消费者，信封，delive

0热度

1回答

从post方法上载src/main/resources中的csv

我已经设置了一个REST API，它允许从批处理输入处具有CSV的POST方法启动Spring批处理作业，但我不知道因为我不能在我的项目maven的src/main/resources中写入csv，所以我知道它在这里是必须写的，因为在生产中，那里存在的文件将在webapp/classes中/ 要使用的。 byte[] fileBytes = Base64.decodeBase64(cleanFil

0热度

1回答

来自mysql的实时数据消耗

我有一个用例，其中我的数据存在于Mysql中。对于Mysql中的每个新行插入，我必须对新数据执行分析。如何我目前解决这个问题是：我的应用程序是一个春季启动应用，我都用调度其检查后每个数据库进入新行2秒。的问题与当前的做法是：即使有在MySQL表没有新的数据，调度火灾MySQL查询，以检查是否新的数据可用。在触发器的任何SQL数据库中解决此类问题的一种方法。但到现在为止，我没有成功地创

1热度

1回答

Spring Batch的鸡和蛋：短暂JPA参考

我有一个春天批处理过程从栏显示，以创建一个新的Foo： /* My Foo Step */ class FooStepConfig { ItemReader<Bar> reader; // Reads records from Bar ItemProcessor<Bar, Foo> processor; // Determines whether to create a ne

2热度

1回答

如何在Spring批处理中使用JdbcPagingItemReader中的limit和offset子句？

该表拥有超过2亿条记录，但我需要限制选定的前500万条记录。我已经用jdbcCursorItemReader尝试了大约2-3个小时来选择并使用单步处理将其写入csv文件，所以我选择使用并行处理，即春季批量提供。我，通过让taskExecutor和JdbcPagingItemReader使每个5个单独的文件百万个，但问题是我无法在查询参数中指定限制和偏移量子句。请帮助我。赞赏比这更好的方法。 <b

0热度

1回答

使用弹簧批红移DATABSE配置数据源时，遇到了异常

我的数据源配置为： dataSource.setUrl("jdbc:redshift://spx....redshift.amazonaws.com:5439/spx"); dataSource.setUsername("spx"); dataSource.setPassword("*****"); 获取例外： - 2017-10-06 15:58:58.670 INFO 5560 ---