問題タブ [spring-cloud-task]

私が見たすべての例 (task-launcherシンクとソース) は、 uri属性でtriggertask定義されたタスクを起動する方法を示しています。私のタスク定義は次のようになります。

私の質問はsampleTaskRunner、ストリーム アプリケーションから構成されたタスク ランナー (DSL で定義されている) を起動する方法です。

ありがとう

アップデート

SCDF REST API を使用してタスクをトリガーする以下のソリューションになりました。

composedTask意味 ：

<timestamp || mySampleTask>

ストリーム定義:

http | httpclient | log

配置プロパティ:

コンポーネントを実装するのは簡単ですがhttp sink、ストリーム アプリケーション スターターがすぐに使えるものを提供してくれると素晴らしいでしょう。

私が抱えているもう 1 つの懸念は、分散環境にデプロイされたときに SCDF REST URL を検出することです。

構成されたタスクのエラー処理動作をシミュレートしています。failedTask構成されたタスクの定義は次のようになります。

<f1: sampleTask --fail=true --custom-argument=someMessage || f2: sampleTask>

sampleTaskクラスランナー：

依存関係:

問題は、 の終了時間がf1DB にレコーダーではなく、failedTaskステータスがSTARTEDダッシュボード UI のように表示されend_time、failedTaskとが両方ともテーブルfailedTask-f1に空であることです。task_executions

以下は、f1実行のログです。

私が削除した場合

依存関係 - 以下の警告ログ メッセージが消え、すべてが期待どおりに機能します。

2017-11-20 12:09:06.920 WARN 28244 --- [ main] o.s.b.f.support.DisposableBeanAdapter : Invocation of destroy method failed on bean with name 'taskLifecycleListener': org.springframework.messaging.converter.MessageConversionException: failed to convert object to Message; nested exception is org.springframework.messaging.MessagingException: At most one parameter (or expression via method-level @Payload) may be mapped to the payload or Message. Found more than one on method [public abstract void org.springframework.cloud.task.listener.TaskExecutionListener.onTaskFailed(org.springframework.cloud.task.repository.TaskExecution,java.lang.Throwable)]

ご意見をお聞かせください。

Spring クラウド データ フローが統合された Spring Batch Web ベース アプリケーションを実行できますか? SCDF を既存の Web ベースの Spring バッチ プロジェクトに統合しようとしています。ここに私のpom.xmlファイルがあります

@EnableTask で注釈を付けたメイン クラス

アプリケーションを実行すると。ログメッセージが表示されます。

osbceAnnotationConfigEmbeddedWebApplicationContext - org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@5fe94a96 を閉じる: 起動日 [Tue Jan 02 16:43:56 IST 2018]; コンテキスト階層のルート

SO 私のアプリケーションは組み込みの tomcat で実行されていません。@EnableTask アノテーションを削除すると、驚いたことに機能します。問題を解決してください