spring-batch

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回答

如何使Spring批處理分區程序中的執行上下文按順序運行

我有一個要求，首先我必須從表中選擇否MasterRecords，然後對於每個MasterRecords，我將不得不提取任何子行和每個子行過程和明智地寫塊。爲此，我在Spring批處理中使用了Partitioner，並創建了主和從屬步驟來實現此目的。現在代碼工作正常，如果我不需要以相同的順序運行從屬步驟，它將被添加到執行上下文中。但是我的要求是以相同的順序爲每個執行上下文運行從屬步驟，並將其添加

1熱度

2回答

Spring批處理與Spring引導 - 配置JobRepositoryFactoryBean

我是新的Spring批處理引導。我在使用postgres作爲數據庫配置jobRepositoryFactory bean時遇到了問題。下面是我的配置類。 @Configuration @EnableBatchProcessing @Import(DataSourceConfiguration.class) public class BatchConfiguration { @A

1熱度

1回答

春天MongoItemReader不讀書單執行的所有記錄

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

1熱度

2回答

Spring：使用FlatFileItemReader

我可以使用FlatFileItemReader而不是批處理的閱讀器嗎？我想用它來解析File。我有讀者豆： <bean id="cvsFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader"> <property name="resource" value="file:${garmin.

0熱度

1回答

Google Cloud上的ETL - （數據流與Spring批處理） - > BigQuery

我正在考慮將BigQuery作爲我的數據倉庫要求。現在，我在谷歌雲（雲SQL和BigTable）中獲得了我的數據。我公開了我的REST API以從兩者中檢索數據。現在，我想從這些API中檢索數據，執行ETL並將數據加載到BigQuery中。我正在評估ETL（每小時數據的每日工作頻率）的2個選項： - 使用JAVA Spring Batch並創建微服務並使用Kubernetes作爲部署環境。它會縮放

0熱度

1回答

在黎明時自動運行批處理

我創建了一個完整的功能性批處理過程，我手動運行運行一個Launcher.java，它具有一個主方法並執行我定義的作業（此作業是我在xml中定義的，它作爲我的主要參數），這很好，現在我期望將它用於生產，爲此我需要配置該進程以在西班牙的每天早晨一天運行，我該怎麼做？這是我的啓動（如果我用鼠標右鍵單擊原樣運行> Java應用程序，它工作正常，但我怎麼做一個批處理，正如我需要它嗎？） public fin

-2熱度

1回答

Spring批處理項讀取監聽器

如何跟蹤FlatFileItemReader何時返回null（即遇到平面文件的結尾）。 ItemReadListener無法正常工作。

-1熱度

1回答

彈簧批處理 - 處理大量數據

我正在尋找一種策略來處理大批量的彈簧批量記錄。讀者只需一行輸入，處理器就可以生成一個尺寸如此之大以至於無法放入內存的項目列表。流程本質上是： read - > generate - > write 不確定是否需要某種嵌套批處理，或許使用tasklet，或者如果我一般持有spring批處理錯誤。