2016-08-17 5 views
1

私は、spring-cloud-dataflow内でspring-cloud-taskを使用して構築されたプロジェクトを使用しています。サンプルプロジェクトとドキュメンテーションを見て、ダッシュボードやシェルを使って手動でタスクを起動するように見えます。 spring-cloud-dataflowはタスク定義をスケジューリングして、例えばcronスケジュールで実行できるようにしますか?私。スケジューリング自体はスケジュールされていませんが、データフローサーバーにデプロイしてそこでスケジューリングを設定する、Springクラウドタスクアプリケーションを作成できますか?私が見ている記事やブログの中でspring-cloud-dataflowは、タスクとして定義されたアプリケーションのスケジューリングをサポートしていますか?

私は次のように気づいた:

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

Q & Aのいくつかは、その後のトリガを参照して、可能性があることこれをヒントが、私は思いますこれはリリースされる前に議論されました。

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

答えて

2

thisを確認してください。これは、春の雲でタスクを引き起こすことを示唆しています。

+0

リンクはもう機能しません。 – indusBull

2

Spring Cloud Data Flowでタスクを起動できる方法はいくつかあります。以下は現在利用可能なオプションです。

  • TriggerTaskを使用して起動します。これをfixedDelayまたはcronの式(例:here)で起動することができます。
  • ストリーミングパイプラインでイベントを介して起動します。 s3バケットまたはファイルシステムディレクトリに新しいイメージ(イベント)があるときに「サムネイル」を作成したいというユースケースを想像してください。この場合、「サムネイル」操作がタスクになる可能性があります(例:here)。

最後に、今後のリリースでは、Spring XDの「スケジューラ」機能をSpring Cloud Data Flowに移植します。

+0

多くの方々のおかげで、TriggerTaskはこれに最適です。さらに質問があります。私はcronパラメータが正しく動作するように見えません。ストリーム定義として試してみました。 triggertask --uri = "file:// C:/Software/timestamp-task-1.0.1.RELEASE.jar" --cron = "0 0 12 * *?" |これは無視され、毎秒1回発生します。 --fixed-delayと--time-unitを使う代わりに、うまく動作します。上記は構文的に正しいですか?ドキュメントやその他の投稿を検索しましたが、--cronを明示的に使用する例は表示されません。 –

+0

最近、 'triggertask'ソースアプリケーションのバグ修正がありました。[#201](https://github.com/spring-cloud/spring-cloud-stream-app-starters/pull/201)を参照してください。 CIの失敗を解決するまで、このアプリケーションをローカルに構築することができます。[この手順](https://github.com/spring-cloud/spring-cloud-stream-app-starters/blob/master/README.adoc)に従います。 。その後、SCDFで 'triggertask'の1.0.3.BUILD-SNAPSHOTリリースを強制登録することができます。もう1つのことは、文書で説明されているように、 '--trigger.cron'にproperty-prefixを使う必要があります。 –

+0

CIビルドが完了し、静的ファイルの1.0.3.BUILD-SNAPSHOTバリアントが生成されました。静的ファイルを使用してください(_eg。for kafka:dataflow:> app import --uri http://repo.spring.io/libs-snapshot/org/springframework/cloud/stream/app/spring-cloud-stream-app- descriptor/1.0.3.BUILD-SNAPSHOT/spring-cloud-stream-app-descriptor-1.0.3.BUILD-SNAPSHOT.stream-apps-kafka-maven --force_)を使用して新しいバージョンのアプリを一括インポートします。 'triggertask'アプリケーションのバグ修正。 –

関連する問題