spring-batch

    0热度

    1回答

    如何从思想上纠正组织文件处理? 我有一个新文件(新)文件夹,旧文件(旧)文件夹,失败文件文件夹(失败)。新文件放入NEW,如果处理正确,则文件转到OLD,如果处理失败,则文件转到ERR。然后我们再次获取这个文件并更正它,并且如果所有的ok文件都转到OLD,并且如果失败转到ERR,那么将它放入NEW。并重复一遍又一遍。 我有一个常量名为“fileHandlingJob”的作业,在作业中我有一些步骤:

    1热度

    1回答

    我有一个现有的spring批处理项目,它根据启动过程中的功能切换决定从MySQL或ArangoDB(NoSql数据库)中读取数据,并执行一些处理并再次写回到MySQL/ArangoDB。 现在MySQL的读写器配置是一样的东西下面, @Bean @Primary @StepScope public HibernatePagingItemReader reader( @Value("

    0热度

    1回答

    您好我想用Spring批处理在Java中运行批处理流程,我需要将batchContext.xml像参数传递给我的主,但我不知道它是如何做到的,这是我启动: public final class Launcher { private static final String LOG_DECORATOR = "****************************************.";

    0热度

    1回答

    我有一个要求,首先我必须从表中选择否MasterRecords,然后对于每个MasterRecords,我将不得不提取任何子行和每个子行过程和明智地写块。 为此,我在Spring批处理中使用了Partitioner,并创建了主和从属步骤来实现此目的。现在代码工作正常,如果我不需要以相同的顺序运行从属步骤,它将被添加到执行上下文中。 但是我的要求是以相同的顺序为每个执行上下文运行从属步骤,并将其添加

    1热度

    2回答

    我是新的Spring批处理引导。我在使用postgres作为数据库配置jobRepositoryFactory bean时遇到了问题。 下面是我的配置类。 @Configuration @EnableBatchProcessing @Import(DataSourceConfiguration.class) public class BatchConfiguration { @A

    1热度

    1回答

    @Bean public Job orderJob() throws Exception { return jobBuilderFactory.get("orderJob").incrementer(new RunIdIncrementer()).listener(listener()) .flow(orderStep()).end().build(); } @Be

    1热度

    2回答

    我可以使用FlatFileItemReader而不是批处理的阅读器吗?我想用它来解析File。 我有读者豆: <bean id="cvsFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader"> <property name="resource" value="file:${garmin.

    0热度

    1回答

    我正在考虑将BigQuery作为我的数据仓库要求。现在,我在谷歌云(云SQL和BigTable)中获得了我的数据。我公开了我的REST API以从两者中检索数据。现在,我想从这些API中检索数据,执行ETL并将数据加载到BigQuery中。我正在评估ETL(每小时数据的每日工作频率)的2个选项: - 使用JAVA Spring Batch并创建微服务并使用Kubernetes作为部署环境。它会缩放

    0热度

    1回答

    我创建了一个完整的功能性批处理过程,我手动运行运行一个Launcher.java,它具有一个主方法并执行我定义的作业(此作业是我在xml中定义的,它作为我的主要参数),这很好,现在我期望将它用于生产,为此我需要配置该进程以在西班牙的每天早晨一天运行,我该怎么做?这是我的启动(如果我用鼠标右键单击原样运行> Java应用程序,它工作正常,但我怎么做一个批处理,正如我需要它吗?) public fin

    -2热度

    1回答

    如何跟踪FlatFileItemReader何时返回null(即遇到平面文件的结尾)。 ItemReadListener无法正常工作。