spring-batch

0熱

1答えて

スプリングブートバッチXMLをJava Configに変換するには、以下のコードをJava Configに変更してください。 <batch:job id="batchJob1"> <batch:step id="step"> <batch:tasklet task-executor="taskExecutor" throttle-limit="${throttle.limit

1熱

1答えて

SpringバッチでNonTransientFlatFileExceptionが発生しました

私は、100レコードを持つCSVファイルを読み込み、10レコードのバッチで一度に処理しようとしていました。すべてが正常に動作しているが、すべてのレコードを処理した後、私は org.springframework.batch.item.file.NonTransientFlatFileException取得しています：リソースから読み込むことができません：[クラスパスリソース [CSV /入力/

-1熱

1答えて

rabbit mqからの読み込みが遅い

私はrabbitmqキューから読み込んでデータストアに書き込む必要があります。現在、キューからメッセージを読み取るのにAmqpItemReaderを使用しています。私が読んだデータはJson形式であり、すべて私のItemProcessorは、jsonをJavaオブジェクトにシリアル化することです。私のシングルスレッドソリューションのパフォーマンスは非常に低いです。私は1秒あたり12msgの割合

0熱

1答えて

Spring Batch：ジョブは、コミット間隔よりも少ない行のチャンクをランダムに選択します。

Spring Batchに問題があります。我々の仕事では、2つの並列ステップのフローを処理するタスク実行プログラム（simpleAsyncTaskExecutor）を使用しています。各ステップにおいて、タスクエグゼキュータは、（マルチスレッドステップの概念を使用して：https://docs.spring.io/spring-batch/trunk/reference/html/scalabil

0熱

1答えて

Springバッチを使用したDB2とMongoDBを使用したSpringバッチ

DB2データベースを読み込み、Springバッチを使用してmongoDBにデータをコピーする必要があります。 mongoDBにデータを書き込むので、トランザクションは必要ありません。私はメタデータテーブルのスクリプトをmongoDBの中にだけDB2ではなく保存したいと思いますが、mongoDB用のメタデータテーブルスクリプトを見つけることができませんでした。サーバの起動時には、spring boo

6熱

1答えて

TransactionRequiredException：JPAItemWriterの使用中にトランザクションが実行されていません。

私は春の起動アプリケーションである奇妙な問題に直面しています。ここで詳細：アプリは、データベースへの書き込みを実行するためのJpaItemWriterを使用しています春のバッチジョブを持っています。また、アプリケーションは次のように ItemWriter構成を休止状態使用するように設定されて： @Bean(name = "itemWriter") @StepScope p

0熱

1答えて

スプリングバッチの環境変数からグリッドサイズ

私はスプリングバッチのパーティションパターンに従っています。現在、私はここで10の固定されたグリッドサイズは、マスタジョブの設定です使用しています： <batch:step id="master"> <batch:partition step="slave" partitioner="rangePartitioner"> <batch:handler grid-size="

0熱

2答えて

データベースから一括データ（動的クエリ）を読み込み、春のバッチを使用してフラットファイルに書き込む

データベースから一括データを読み込みたい場合、テーブルを読み込むクエリが動的になります（テーブル名は設定ファイルから選択されます）。デリミタでフラットファイルにデータを書き込む。テーブル名自体は動的なので、どのrowmapper/DTO/VOクラスでも使用できません。カスタムデータを読み込み、一部の区切り文字でフラットファイルに書き込んでいます。春のバッチでこれを達成する方法を特定するお手伝

0熱

1答えて

バネバッチ、行ごとに読み込む前に全体のcsvファイルを読む

私はcsvファイルを読み込み、他の外部システムからのデータで各行を充実させ、新しいエンリッチcsvをいくつかのディレクトリに書き出します。今すぐデータを取得してください外部システムから私は各行を1つずつ渡し、外部システムから新しい列を取得する必要があります。しかし、私は外部システムからperticularの列のすべての値を送信して得た値を渡す必要がある各行で外部システムを照会する。例えば -