0

SQL ベースのウェアハウスから mongo に毎日データを移動する必要があるユースケースがあります。この ETL ジョブのツールとして SpringXD を選択しました。ただし、毎日変化するクエリにいくつかのワイルド カード パラメータを渡す必要があります。Spring XD を使用しているときに、SQL 選択クエリにワイルドカード パラメータを渡すためのサンプル DSL を誰かが知っているか、提供できるかどうか疑問に思っていました。

4

1 に答える 1

1

これは、SpringXD Rest API の優れた使い方です。 http://docs.spring.io/spring-xd/docs/1.3.1.RELEASE/reference/html/#REST-API

できることは、必要なジョブ パラメーターを使用してストリームをプログラムで展開する小さなスクリプトまたはアプリケーションを用意することです。ジョブ「myBatchJob」と、変更される 2 つのパラメーターがあるとします。String パラメータをレスポンスにエンコードするだけで、パラメータを何度でも変更できます。これは、ジョブのデプロイを XD Rest API に投稿する Python の例です。エンコードされたパラメーターを正しく取得するのは少し難しいかもしれませんが、探している柔軟性を得るためにはやり遂げる価値があります

       import urllib2
       req = urllib2.Request('http://localhost:9393/jobs/executions?jobParameters=%7B%22-myParameter1(string)%22:%22foo%22,%22-myParameter2(string)%22:%22bar%22%7D&jobname=myBatchJob')
       response = urllib2.urlopen(req)
       print response.read()
于 2016-06-21T15:14:16.800 に答える