spring-batch

0熱

0答えて

私のデータがMysqlにあるユースケースがあります。 Mysqlに新しい行を挿入するたびに、新しいデータの解析を実行する必要があります。私のアプリケーションは、新しい行をチェックし、私はスケジューラを使用しているに春ブーツアプリケーションは、すべての後にデータベースに入力されている：私は現在、この問題を解決していますがでどのように 2秒。現在のアプローチと問題がです： MySQLのテーブルで利

2熱

1答えて

SpringバッチでJdbcPagingItemReaderのlimitとoffset句を使用する方法は？

テーブルには2億以上のレコードがありますが、上位5百万レコードを制限する必要があります。私はjdbcCursorItemReaderを試してみましたが、それは2-3時間かけて選択し、それをcsvファイルに書き込んで、チャンク処理でシングルステップを使用しています。そのため、バージョンをバッチ処理する並列処理を選択します。私はtaskExecutorとJdbcPagingItemReaderを持っ

0熱

2答えて

春バッチ - ItemWriter - DataIntegrityViolationException - レコードをスキップ - 再試行 - 動作していません

いつかこの問題が発生しています。私は3.0.7 問題がItemWriter内の1つのレコードにorg.springframework.dao.DataIntegrityViolationExceptionの場合で、スプリングバッチを使用しています、チャンク内のレコードの残りの部分（チャンクサイズ= 10）ですskipPolicy（すべての例外に対してtrueを返す）を提供した後でも、DBに挿入さ

0熱

1答えて

どのようにファイルリーダーからファイルライターのスプリングバッチにファイル名を渡す

私はフォルダから複数のファイルを読んでいます。ファイル名がtest1.txt、test2.txt、test3.txtのようになっているとします。これらのファイル名をライターに渡し、 'test1.xml' 'test2.xml' 'test3.xmlのような出力ファイル名を生成したいと思います。これに関するお手伝いをお待ちしております。 @Autowired public StepBuilde

0熱

1答えて

ListenerExecutionFailedException：リスナーが例外をスローしました

おそらくRabbitMQによってスローされる次の例外を防ぐために何が必要ですか？ org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception at org.springframework.amqp.rabbit.listener.

0熱

1答えて

バッチ・バッチ内のキュー・ジョブ・インスタンス

別のシステムからトリガーされた、毎週バネ・バッチで実行されているジョブがあります。時には、同じ日に実行されるジョブのインスタンスがいくつかあります。それぞれが他のシステムからトリガーされました。すべてのジョブは約1時間実行されます。実行するジョブインスタンスが複数ある場合は、データに問題が発生します。実行中のジョブ・インスタンスがない場合は、次のようにこのステップを最適化します。ジョブ・インス

0熱

1答えて

春のバッチで、ItemWriterからSkipListenerにパラメータを渡すにはどうすればいいですか？

私の春のバッチジョブで、itemWriterがエラーを書き込んでいる間に、それはスキップされます。そして、ItemSkipListenerがそれを受け取ってアイテムをファイルに記録します。私のアイテムには1つのリストデータがあり、リストのどの要素がエラーになったのかを知りたい。しかし、ItemSkipListenerでは、itemとthrowableしか知ることができません。（リスト内のどの

0熱

1答えて

バネ統合：ソリューション/複数のSFTPサーバーを接続するためのヒント？

私の春のバッチプロジェクトは、複数のSFTPサーバーからファイルをダウンロードする必要があります。 sftp host/port/filePathは、application.propertiesファイルで設定されています。これらのサーバーとダウンロードファイルを接続するために、バネ統合「sftpアウトバウンドゲートウェイ」を使用することを検討します。しかし、私はどのようにこの種の設定（私はjava

0熱

2答えて

java 8並列ストリームとバネバッチの比較

私はメッセージをいくつかの他のアプリケーションで作成し、私のアプリケーションはキューをポーリングしてすべてのメッセージを取り出し、他のオブジェクトに変換してデータベースに保存するキューを1つ持っています。これには2つのアプローチがあります。 1）スプリングスケジューラを使用し、すべてのメッセージを5秒ごとにポーリングし、java 8のパラレルストリームを使用してデータベースに保存します。 2）春

0熱

2答えて

Spring Batchの入力として何千ものjpegファイルの名前を読む

私はSpring Batchを使用していて、バッチ処理のジョブを定義していますが、特定のディレクトリから80.000個のjpegファイルの名前を入力する必要があります。チャンクごとに例えば1000を読みたいとします。私はSpring Integrationについてこれについても聞いたことがありますが、これが正しいかどうかわかりません。私は正しいアプローチを取っているかどうかを教えてください。