問題タブ [spring-cloud-task]

Spring Boot/Spring Batch アプリケーションで Atomikos を動作させようとしています。

私のコードの関連部分は次のとおりです。

データソース構成:

Atomikos 自動構成の依存関係:

私のapplication.properties：

自動構成レポートは次のとおりです。

Atomikos が自動構成されない理由がわかりません... 誰か助けてもらえますか?

edit : JTA transactionManager Bean をコメントアウトしたところ、次の自動構成レポートが表示されました。

Atomikos トランザクション マネージャーがピックアップされていることを確認するにはどうすればよいですか?

編集2TransactionManager :次のようにクラスを除外しました:

しかし、私はまだ私にいくつかのクラスの1つを強制しSimpleBatchConfigurationているようです:SimpleTaskConfigurationTransactionManager

AtomikosJtaConfiguration一致しない原因...

Atomikos の自動構成を機能させるためのベスト プラクティスを教えてください。

スプリング ブートで構成されたスプリング バッチ/スプリング クラウド タスク アプリケーションの XA/分散トランザクションを構成しようとしています。

春のブート自動構成に依存することを期待して、次の依存関係を追加しました。

ただし、次の 2 つのクラスにより、2 つのトランザクション マネージャーが構成されます。

• org.springframework.cloud.task.configuration.SimpleTaskConfiguration

• org.springframework.batch.core.configuration.annotation.SimpleBatchConfiguration

次のメッセージを参照してください。

PlatformTransactionManager名前付きが構成されているためtransactionManager、atomicos の自動構成が取得されません。

transactionManager上記の2つのクラスによって引き起こされる豆の不当な強制を防ぐのを手伝ってもらえますか?

既存のレガシー Java バッチ アプリケーションを廃止し、利用可能な最新のバッチ フレームワークで再作成する予定です。大量のバッチ ジョブをモダナイズする必要があるため、次のことを可能にするフレームワークまたはアーキテクチャを探しています。

1. 既存のデプロイされたアプリケーションに影響を与えることなく、新しいバッチが作成されたときに動的にデプロイできるバッチ ソリューションを開発します。- Spring クラウド タスクはこの機能を提供しますか? 注: アプリをローカル サーバーにデプロイすることだけを考えており、クラウドとは関係ありません。
2. Spring Batch/Boot がバッチ アプリケーションに通常期待される機能を提供できる場合、Spring Cloud Task に追加される特別な付加価値は何ですか? - オンラインで入手できる Spring のドキュメントからは、これを完全に理解できませんでした。
3. Spring Cloud Task のドキュメントから、アプリケーションがその中に多くのタスクを持つことができることを理解できました。各タスクに独自のライブラリ依存関係があり、他のタスクの依存関係と矛盾する可能性がある場合はどうすればよいですか? その場合、これらの各タスクを新しいアプリケーションに移動する必要がありますか、それとも回避策がありますか?

タスク アプリを Spring Cloud Data Flow に登録し、その定義を作成しましたが、ステータスが「不明」と表示されます。ストリームを作成し、タスク シンクからタスクを起動しようとすると、エラーが発生します。

タスクシンクからタスクを起動するには? 何か不足していますか？どんな助けでも大歓迎です。もう 1 つの質問は、自分のタスクで TaskLaunchRequest を介して送信されたペイロードにアクセスする方法です。S1 http | step1: トランスウサギ | ログ S2 :S1.step1 > フィルター --expression=payload.contains('CUSTADDRMODRQ_V15') | タスクプロセッサ | タスクシンク

task-sink は、TaskLaunchRequest の uri によって提供されたタスクを起動しています。ログに示されているようにリソースを探しています OUT /home/vcap/.m2/repository に優先度 10.0 のマネージャー EnhancedLocalRepositoryManager を使用します https://repo.spring.io/libs-snapshotに優先度 5.0 のトランスポーター HttpTransporter を使用しますついに失敗。

タスクはリポジトリにデプロイされ、前述のように、その定義も登録して作成しました。

これはcf環境にあり、SCDFサーバー1.0.0.M4を使用しています。task-sink の application.properties で、maven.remote.repositories.snapshots.url=** を提供しています

task create fis-ifx-event-task --definition "fis-event-task"

私の目標は、ストリームからタスクを起動することです。

情報のおかげで。1.0.0M4 バージョンではタスクを有効にできないため、実際には BUILD-SNAPSHOT を使用しています。これは、私が spring-cloud-dataflow-server-cloudfoundry-1.0.0.BUILD-20160808.144306-116 を使用しているものです。タスク定義を登録および作成できます。チームから提供されたサンプル タスク モジュールを使用している場合でも、タスク定義のステータスが「不明」と表示されます。しかし、ストリームのフローを開始し、タスク シンクがタスクを起動しようとすると、Maven リソースが見つかりません。タスク定義を作成すると、タスク モジュールはデプロイされますか? Pivotal Apps Manager にアプリが表示されません。前述のように、タスク シンク アプリケーションの application.properties ファイルに maven.remote.repositories.snapshot.url を指定しました。私が観察したもう 1 つのことは、データフロー シェルから手動でタスクを起動すると、CF-UnprocessableEntity(10008): The request is semanically invalid: Unknown field(s): 'staging_disk_in_mb', 'staging_memory_in_mb' というエラーが表示されることです。ソースが空です。現在、タスクはタイムスタンプを出力することになっており、入力に依存していません。

投稿の前半で使用しているストリームを提供しました。ここでわかるように、シンクは uri とペイロードを含む TaskLaunchRequest を受信して​​おり、タスクを起動できません。

spring-cloud-dataflow 内で spring-cloud-task を使用して構築されたプロジェクトの使用を検討してきました。サンプル プロジェクトとドキュメントを見ると、タスクはダッシュボードまたはシェルから手動で起動されているようです。spring-cloud-dataflow は、たとえば cron スケジュールで実行できるように、タスク定義をスケジュールする方法を提供しますか? つまり、それ自体がスケジュールの知識を持たない spring-cloud-task アプリを作成できますが、それをデータフロー サーバーにデプロイし、そこでスケジュールを構成できますか?

私が見た投稿やブログの中で、次のことに気付きました。

https://spring.io/blog/2016/01/27/introducing-spring-cloud-task

その後のQ&Aのいくつかは、トリガーに言及して、これが可能性であることを示唆していますが、これはリリース前に議論されたと思います.

アドバイスをいただければ幸いです。

クラウド タスクをスケジュールし、ストリームを使用して実行するように構成できることも知っています。開発者として、タスクをオンデマンドで実行できるように、rest-api を使用して春のクラウド タスクを実行したいと考えています。基本的に私はワークフロー管理システムを持っており、control-m エージェントを使用しています。したがって、一部のジョブは control-m によって実行され、一部のタスクは Spring クラウド データフロー サーバーにデプロイされます。1 つのジョブが完了したら、クラウド上にある別のジョブを実行する必要があります。そのためには、Rest API を呼び出してクラウド タスクをオンデマンドで実行する機能が必要です。この機能が必要だと確信していますが、ドキュメントの例が見つかりません。誰か助けてください。前もって感謝します。

私はSpringクラウドタスクとSCDFの学習が初めてなので、これを尋ねます。

イベントに基づいて SCT を実行したい (メッセージが Rabbit MQ に投稿されたとします) ので、次の 2 つの方法で実行できると思います。

1. RabbitMQ からメッセージをポーリングし、データをストリームに送信するソースを作成します。次に、ストリームからデータを読み取るシンクを作成します。データが (ソース ストリームから) シンクに到達するとすぐに、タスクが起動されます。

   これが可能かどうかわかりませんか？

2. 別の方法として、タスク ランチャーを使用することもできます。ここで、タスク ランチャーはストリームで構成され、リスナーは rabbitMQ からのメッセージをポーリングします。メッセージが受信されると、トリガーがプロセスを開始し、タスクランチャーがタスクを起動します。しかし、どうすればメッセージデータを自分のタスクに入れることができるかわかりませんか? データを TaskLaunchRequest に追加する必要がありますか?

   /li>

現在、私は自分のアカウントで重要なパブリック クラウドでスプリング クラウド タスク機能を使用しようとしています。API バージョンは 2.63 です。spring クラウド タスク ドキュメントから完全なサンプル コードのみをコピーし、ローカルでビルドおよびパッケージ化してクラウド ファウンドリにプッシュし、manifest.yml で「no-route: true」および「health-check-type: none」を指定するだけです。サンプルを正常に実行してコンテナを破棄した後、ログに「Process has crashed with type: web」というエラー情報が表示されます。依存関係から判断すると、私は spring-cloud-task-core と spring-boot-starter しか使用していないため、なぜクラウド ファウンドリーは私のアプリケーションが Web ベースのアプリケーションであると考えるのでしょうか。この種のチェックを回避するように設定したにもかかわらず、ヘルスチェックを実行するのはなぜですか?