問題タブ [spring-xd]

単一ノードの Spring XD をセットアップし、XD シェルを実行しました。これらを実行しているホストはインターネットに公開されていないため、Spring XD からすぐに使用できる twittersearch ストリームを使用できません。java.net.UnknownHostExceptionをスローします: api.twitter.com

ここで私の質問は、Spring XD にプロキシの詳細を設定して、それらを使用して Twitter にアクセスできるようにするにはどうすればよいですか?

私の仕事では、パーティション化されたcsvへのデータベースエクスポートがあります。次のステップでは、MultiResourceItemReader を使用してこれらのファイルを 1 つのファイルにマージします。

私の問題は、マージ ステップの開始時にファイルが利用できないように見えることです。この例外が発生します

ただし、ジョブが失敗した後、すべてのパーツ csv ファイルがエクスポート ディレクトリで利用可能になります。春のバッチリファレンスでは、実際にはこの非常にアーキテクチャ上の考慮事項が16ページにリストされています。

また、アーキテクチャは、パーティションの統合を考慮する必要があります。主な質問は次のとおりです。 • 次のジョブ ステップに進む前に、すべてのパーティションを終了する必要がありますか。

ドキュメントと Web を検索して、次のジョブ ステップに進む前にすべてのステップ パーティションが完了していることを確認する方法の答えを探しましたが、答えが見つからないようです。

それは一般的な考慮事項であるに違いありませんが、明らかに何かが欠けています。

モジュール「source:trigger」が Spring XD でどのように機能するかについて、少し混乱しています。ドキュメントに基づいて、開始日と固定遅延を指定できます。理論的には、トリガーを定義するストリームはその時点でのみ開始し、固定遅延に基づいて繰り返す必要があります。

例えば：

展開されると、このストリームは 12/08/14 の 23:35:00 に初めて起動されることが期待されます (日付形式 = "MM/dd/yy HH:mm:ss" を使用)。ただし、時間に関係なく、デプロイされた直後に起動されます。

ログが示すように、ストリーム「s1」は実際には予想よりも早い 23:33:28 に開始されます。開始されると、固定遅延で構成されているように 10 秒ごとに繰り返されます。

では、なぜこのストリームは「日付」パラメーターを考慮せず、展開されるたびに起動するのでしょうか? これはバグですか、それとも Spring XD で予想される動作ですか? 後者の場合、そのようなトリガーを設定して、特定の時間にのみ起動するにはどうすればよいですか?

ところで、Spring XD が作業しているのと同じ TimeZone を使用するようにするためだけに、システム プロパティ「user.timezone」を「CET」に設定して Spring XD を起動しました。

たとえば、Spring-XD でストリームを 'source1 | 'source1' モジュールにはオプション 'option1' があります。

私がやりたいのは、複数のインスタンスを持つように「source1」を構成することです (これは Spring-XD で実行可能です)。同時に、「source1」の各インスタンスが「option1」で異なる値を持つようにするのも好きです。

Spring-xd で現在利用可能な DSL 設計で可能ですか?

目標は、ネットワーク経由で送信されたデータを読み取ることです。

データ生成側では、stdout に吐き出すアプリがあります。このデータの内容は JSON 文字列です。

これが私がやっていることです（Linux Mint 17で、BSDフレーバーのnetcatを使用しています）：

データ生成:

SpringXD の場合: (with xd-singlenode)

出力：

これはユーザー エラーであると確信していますが、正しくするために何を変更すればよいかわかりません。

これを行うと、期待どおりに機能することに注意してください。

Spring-XD では、キュレーター接続がタイムアウトします。

警告 ConnectionStateManager-0 curator.ConnectionState - 63021 (最大タイムアウトの 60000 を超える) 後に接続試行が失敗しました。接続をリセットし、新しい接続で再試行しています。

Curator は接続の再確立を試みますが、失敗します。以下のログを確認してください。誰かが同様の問題に直面しましたか? この問題を解決する方法、または回避策をご存知でしたら教えてください。

また、デフォルトの Curator 接続タイムアウトは 60000 です。これを増やす方法はありますか? spring-xd は設定可能なプロパティを公開していますか?

私は、activemq 5.9 と spring xd 1.1 を使用しています。activemq トピックをサブスクライブしたい。だから、私はjmsソースを使用しています。Activemq は、*、> などのワイルドカードをサポートしています。> は、この名前から始まる任意の宛先に再帰的に一致させるために使用されます。このワイルドカードを使用して、次のように jms ソースをサブスクライブしようとしています:
stream create --name streamname --definition "jms --clientId=1 --destination=springin.> --durableSubscription=true --pubSub=true --subscriptionName=streamName | null"

エラー :コマンドが失敗しました org.springframework.xd.rest.client.impl.SpringXDException: XD133E:(pos 42): 'queue' または 'topic' のチャネル プレフィックスが必要ですが、'--' jms --clientId=1 -- が見つかりましたdestination=springin.> --durableSubscription=true --pubSub=true --subscriptionName=streamName | ヌル

しかし、私がこのようなことをしようとしているとき:
stream create --name streamname --definition "jms --clientId=3 --destination=springin.*.tp1 --durableSubscription=true --pubSub=true --subscriptionName=streamName | null"
ストリームが作成されています。

したがって、'*' はサポートされていますが、'>' は機能しません。この「>」ワイルドカードを使用したい。これに対する回避策はありますか?