spring-batch

0熱

1答えて

スプリングバッチ/ブーツは、複数のJSONにCSV形式に変換し、Marklogicデータベースへの書き込み

Iは、リーダビーイングは、私は、そのオブジェクト内の異なるオブジェクトを取り、別のJSONファイルとして記述する必要が複合オブジェクトにファイルを変換するために使用される要件を有します。これは、csvファイルの1行分を意味し、複数のjsonsファイルが作成され、Marklogicデータベースに書き込まれる必要があります。私は単一の出力ファイルにファイルを変換するために、複数の項目ライターを使用し

0熱

2答えて

スプリングバッチライターで再試行

ライターで再試行を使用しているバネバッチがあります。筆者はこのようになります：「DB操作2」で例外がある場合 public class MyWriter implements ItemWriter<MyClass> { @Retryable(maxAttempts=3, [email protected](delay=2000)) public void write(List

0熱

1答えて

スプリングブート/バッチディスエーブルコードによるバッチ自動スタート

私は、特定の順序で実行する必要のある異なるジョブからなるスプリングバッチアプリケーションを作成しています。私はJobLauncherから手動でジョブを実行している、と私は私のプロパティで次のプロパティを追加することによって、春のバッチが提供するオートスタート機能を無効にすることを行うためにをファイル： spring.batch.job.enabled=false 私は無効にしたいと思いますこ

1熱

1答えて

Bitronixトランザクションが途中でコミットされているようです

bitronixトランザクションマネージャを使用するバッチ処理があります。特定のステップの最初のパスでは、トランザクションの境界に達するとデータがターゲット・データベースにコミットされるだけで、予期されたコミット動作が確認されます。ただし、2回目以降のパスでは、行は書き込まれるとすぐにコミットされます。つまり、コミットポイントを待つことはありません。ビットロニックスのコミットが予想されるポイン

0熱

3答えて

いくつかのレコードを挿入してもデータベースに行を挿入する方法

私は春バッチで作業しており、一部の行を挿入しなくてもデータベースに行を挿入できます。 1つのレコードが挿入されていなくてもジョブが失敗した場合に、バッチを更新/挿入する方法を理解できません。データベース内のデータをプッシュするための挿入/更新クエリを使用します。

0熱

1答えて

アプリケーションコンテキストNullで別のプロジェクトにあり、豆にアクセスできない

私は@componentを使って宣言されたBeanとアプリケーションコンテキストを使用しているプロジェクト（project1）を持っています。今私はこのプロジェクト1を依存として使用している別のプロジェクト（スプリングブートプロジェクト - プロジェクト2）があります。私はautowired注釈を使用してproject1のbeanにアクセスしようとしていますが、BeanとApplicationコ

0熱

1答えて

SpringバッチはJobインスタンスをデータベースに挿入しません

私はSpringバッチを既存の環境に実装しようとしています。私のスプリングバッチは正常に動作しますが、スプリングバッチテーブルにインスタンスを挿入していないようです（Batch_job_execution、...）なぜ失敗していないのか分かりませんし、バッチの像が完成しました？どうすればこの問題を解決し、私の春のバッチを既存の設定に関してどうやって設定できますか？私は、トランザクションマネ

0熱

1答えて

SpringバッチをリモートCassandraデータベースに接続する

私は、CSVファイルからデータを読み取り、そのデータを処理してリモートデータベースにアップロードしたいと考えています。私は春のスターターレポをbaseとして使用しています。コードは、私はプロパティでこの情報を入れてみましたhere がファイルです： spring.data.cassandra.contact-points=IP, IP spring.data.cassandra.port=POR

0熱

1答えて

春バッチアプリケーションのPCFインスタンスで読み取られた同じデータ

JdbcCursorItemReaderを使用してデータベースからデータを読み取るSpringバッチアプリケーションで作業していますが、このアプリケーションは単一のインスタンスを実行すると正常に動作します。このアプリケーションをPCFにデプロイし、自動スケール機能を使用しましたが、複数のインスタンスがデータベースから同じレコードを取得しています。他のインスタンスから重複したデータの読み取りを防

1熱

1答えて

今のところカサンドラデータベース

への書き込みに春のバッチを使用して、私は次のコードを経由してカサンドラに接続することができるよ： import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Session; public static Session connection() { Cluster cluster = Cluste