私が見たすべての例 (task-launcherシンクとソース) は、 uri属性でtriggertask定義されたタスクを起動する方法を示しています。私のタスク定義は次のようになります。
sampleTask <t2: timestamp || t1: timestamp>
sampleTask-t1 timestamp
sampleTask-t2 timestamp
sampleTaskRunner composed-task-runner --graph=sampleTask
私の質問はsampleTaskRunner、ストリーム アプリケーションから構成されたタスク ランナー (DSL で定義されている) を起動する方法です。
ありがとう
アップデート
SCDF REST API を使用してタスクをトリガーする以下のソリューションになりました。
composedTask意味 ：
<timestamp || mySampleTask>
ストリーム定義:
http | httpclient | log
配置プロパティ:
app.http.port=81
app.httpclient.body=name=composedTask&arguments=--increment-instance-enabled=true
app.httpclient.http-method=POST
app.httpclient.url=http://localhost:9393/tasks/executions
app.httpclient.headers-expression={'Content-Type':'application/x-www-form-urlencoded'}
コンポーネントを実装するのは簡単ですがhttp sink、ストリーム アプリケーション スターターがすぐに使えるものを提供してくれると素晴らしいでしょう。
私が抱えているもう 1 つの懸念は、分散環境にデプロイされたときに SCDF REST URL を検出することです。