spring-xd

0熱

1答えて

バッチジョブによるデータの取り込みにspring-xdを使用しています。適切な数のジョブが4つのコンテナで並行して実行されます。 10と40の間のジョブ。これらのほとんどは1分以内で完了します。私は、データストアにredis（rabbitmqではなく）とmysqlを使用しています。 Spring-xd-batchは、ジョブ/ステップの統計に異なるmysql-dbを使用し、私のアプリケーションは独自

0熱

1答えて

Spring Xdストリーム用にコンテナがありません

分散モードでSpring XDを実行しています。しかし、私がコンテナを立ち上げると、管理ノードはそれを見て、すべてのストリームではなく一部を展開します。ここに管理者のログがあります :11:41+0000 1.3.0.RELEASE INFO DeploymentSupervisor-0 zk.ContainerListener - Container arrived: Container{

0熱

2答えて

WindowsでSpring XDを使用する方法

Spring XDをダウンロードしてプログラムファイル内のフォルダを解凍した後、xd-singlenodeコマンドを使って試してみました。そうした後、春XDは、夫婦のみ秒間動作しているように見えますし、私がトラブルそれを解く/通訳を持っています、次のエラーを、送信します。 C:\Program Files\spring-xd-1.2.0.RELEASE\xd\bin> xd-singlenode

0熱

2答えて

SPRING XD：モジュールを「自動的に」アップロードする方法はありますか？

スクリプトのようなものを使ってモジュールをアップロードする方法はありますか？たとえば、私たちにはたくさんのモジュールがあり、モジュールの新しいバージョンを使用する準備が整うたびに、モジュールを1つずつアップロードすることは楽しいことではありません。

1熱

1答えて

rabbitmq設定を春にxd

1）spring-xd rabbitmq 'requeue = false'オプションが機能しません。以下の両方の設定結果は同じです。私は 'requeue'オプションを 'false'に設定しましたが、rabbitmqは常に再キューを試みます（=再試行）。これらのオプションの間に優先順位はありますか？（maxAttempts priority> requeue priority）ですか？

0熱

1答えて

Spring XD：ストリームをアンデプロイ中に処理されているメッセージを処理する方法

ストリームアンデプロイ操作が発生している間にメッセージを再キューするためのカスタマイズがありますか？ RabbitMQのアンパックされたメッセージがアンデプロイ中に遅いプロセッサによって処理されているとします。「ディスパッチャにはサブスクライバがない」ためにメッセージがDLQに配信されないようにする方法はありますか？入力プロセッサのキューに入れられますか？

0熱

1答えて

Spring-XDジョブメール通知

Spring-XDを使用して毎日ほとんどジョブを実行していないため、ジョブが失敗する可能性があります。 Spring-XDには、ジョブの詳細を示すダッシュボードがあり、ジョブの詳細を取得するために使用できるREST APIもあります。私たちは、ジョブの失敗やすべてのジョブのステータスを含む1つのメールの送信時にメール通知を送信することで、このプロセスを自動化する予定です。我々は、RESTのAP

0熱

1答えて

SpringXDは：seprateライン

にジョブ定義を作成するにはどうすれば非常に長いジョブ定義を持っています。読みやすいように複数の行に分ける方法があるのだろうかと思います。私は「\」で試してみましたか「\ n」はそれらはすべて、たとえば、雇用創出に失敗している： xd:>job create --name myHttpJob --definition "httpJob \n job create --name myHt

0熱

1答えて

bigdata用のSpring-XD springアプリケーション

私はSpring-XDの新機能で、ファイルとして大きなデータをhadoopに保存するのに役立つという基本的な考え方しか持っていません。 Spring-XDを使ってソケットに入ってくるデータをhadoopに保存するためのアプリケーションを開発したいと思います。これは可能ですか？はいの場合は誰でも私がいくつかの例を教えてくれるのですか？ https://github.com/spring-proj

0熱

1答えて

spring xd jdbc sinkを使用して、トップレベルでないJSON要素をテーブル列に保存する方法は？

私はメッセージ・バスからこれらのイベントを取得し、次の列イベントIDとリレーショナル表にメッセージを記述する必要が午前次のようなデータ構造 { metadata: { eventId:string eventName: string ts: date time string . . . }, data:{ // complex event