問題タブ [spring-cloud-dataflow]

現在、Spring Cloud Data Flow は oAuth 認証をサポートしており、Cloud Foundry で LDAP を使用して Spring Cloud Dataflow サーバーを認証したいと考えています。私がそれを行う方法はありますか?、利用可能なドキュメントはありますか?

ソースとしてkafkaトピックを試すと、kafka例外が発生します

これが私がストリームを作成した方法です

実行中にログファイルで例外が発生します

このプロパティを設定すると言及されているいくつかのスレッドを見ました-「spring.cloud.stream.bindings.input.consumer.headerMode = raw」が役立ちますが、どういうわけかこれは機能しません。

Sink と Source の両方のバインディングを持つ Spring Cloud Stream App である Spring Boot Application を作成できますか?

タスク アプリを 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 Data flow と Stream Cloud Streaming Applications の初心者です。現在、私のプロジェクト図は次のようになっています。

zuul API ゲートウェイを使用して外部クライアントからの POST 要求を Composite というマイクロサービスにルーティングします。Composite は REST POST を使用してストリームを作成し、Spring Cloud Data Flow Server にデプロイします。私の知る限り、マイクロサービスの mongodb とファイルは、共存する JVM プロセスとして実行されます。私のクライアントがストリームのステータス、処理されたデータのステータスを知る必要がある場合、複合マイクロサービスは Spring Cloud Data Flow Server とどのように対話する必要がありますか? 現在、ストリームを展開するために POST 呼び出しを行うと、SCDF サーバーからステータスを取得することさえできません。SCDF は、個々のアプリを調べるためのフックを公開していますか? また、フロー @runtime を変更して動的メッシュを作成するにはどうすればよいですか?

現在、私は Local Spring Cloud Data Flow Server を開発に使用しています。

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のいくつかは、トリガーに言及して、これが可能性であることを示唆していますが、これはリリース前に議論されたと思います.

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