現在のチャンクコンテキストでItemReaderを使用するには？

Question

spring-batchのItemReaderを作成しようとしています。しかし、読者は各chunkに再度呼び出すと、（URLのページネーションのいくつかの種類につながる）チャンクパラメータを使用して追加データをフェッチする必要があります。

で構成

private final RestTemplate tempalte = new RestTemplate(); 

@Bean 
public ItemReader<MyDTO> getReader() { 
    return tempalte.exchange(url, HttpMethod.GET, headers, currentChunkIndex); //TODO how to? 
} 

：

@Bean

public Step step() { 
    return stepBuilder.get("jobname") 
     .<MyDTO, MyEntity>chunk(100) 
     .reader(getReader()) 
     .writer(getWriter()) 
     .build(), 
} 

質問：私はこれを達成できましたか？各chunk繰り返しでリーダーをリフレッシュし、さらにチャンクインデックス自体を使用しますか？

Answer 1

このメソッドがnullを返すまで、Spring Batchフレームワークは引き続きreader.read()を呼び出します。あなたがここに従わなければならないパターンは、あなたの読者にItemStreamを実装させ、updateメソッドを使用してページネーションブックマークを移動することです。

ジョブの実行中に、自分の進捗状況を追跡する状態変数をリーダーに保持します。また、エラーが発生した場合は、メソッド（ItemStreamの一部も含む）は、ステップのExecutionContextから状態を取得して、中止した箇所を取得します。 ItemStreamの詳細はhere in the Spring Batch docsです。

注：StepExecutionListenerを代わりに実装することで、非常に近いものを達成することもできます。