問題タブ [spring-xd]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring-xd - ActiveMQ は、Spring XD で将来的にトランスポートとしてサポートされますか?
標準のメッセージング プラットフォームとして ActiveMQ を使用しています。XD はすでに ActiveMQ を JMS ソースとしてサポートしています。トランスポートとしてのメッセージング プラットフォームは、トランスポートにちなんで名付けられた ERROR キューにペイロードを入れることで、シンクの失敗を処理するのに役立ちます。Redis の場合、ペイロードは LIST に入ります。キューは、バッチ ジョブを使用して失敗したメッセージを処理するための優れた方法です。将来、ActiveMQ がトランスポートとしてサポートされるかどうか疑問に思っています。
spring-xd - Spring XD 分散環境
私はSpring XDとGemFire XDに取り組んでいます。Spring XD の分散環境がどのように機能するかを理解したい。spring xd がトランスポートとして redis または rabittmq を使用することは知っています。
私はこれについて明確です.Spring xdとrabittmqを1台のマシンにインストールしました。redis.properties ファイルを変更し、ホスト名を追加しました。
すべてのマシンに spring xd をインストールする必要がありますか? もしそうなら、インストール後、それらを立ち上げる方法。
マスター マシンで、./xd-admin と ./xd-container を実行します。
xd-admin からの指示をリッスンできるように、ノード (Spring xd インスタンス/ワーカー) をどのように起動しますか?
これについて私を助けてください。
ありがとう、 -スヨダン
spring-xd - Spring XD ストリームの障害処理
次のようなストリームがあります。ソース(jms-ibmmq) -> プロセス -> プロセス -> シンク(jdbc-oracle)
データの取り込みは正常に機能します。しかし、ストリームの一部として、シンク (jdbc-oracle) がダウンする可能性があります (または) oracle db への永続性を妨げるネットワークに問題がある可能性があります。
私が求めているのは、この失敗を処理する方法と、Spring xd がすぐに提供できるオプションは何ですか? 処理/シンクモジュールを引き起こしたストリームでこれらの障害を処理するために一般的に使用されるパターンはありますか?
spring-xd - 起動時/スクリプトでストリームを作成
xd-shell 経由で手動で入力することなく、spring-xd コンテナーの起動時にストリームを作成しようとしています。したい; 1. xd-singlenode を起動する (bash 経由で呼び出す) 2. 事前に作成されたストリーム定義 (例: http --port=8080 | file) をコンテナーの起動後にデプロイする
( ) を呼び出す URL があることは知っていcurl -POST http://127.0.0.1:9393/streams?name=mystream&definition=http|fileますが、追加の構成 ( など--port=8080) を指定する際に問題があり、パイプ ( |) もいくつかの問題を引き起こしています。
ありがとう
spring-xd - 構成されたモジュール内のモジュールのカウントを指定する方法は?
たとえば、「myprocessor」として構成されたモジュールを作成したいと思います。
また、構成モジュール内で、processor1、processor2、processor3 の数を 4:2:1 にして、それらの間のすべての通信がインプロセスになるようにしたいと考えています。
どうすれば達成できますか？次のようなコマンドを使用して、作成中に指定できますか?
または展開中？
ありがとう、
サイモン
java - spring xd を使用して Hadoop にデータをロードする
HTTP ソースと HDFS シンクの間にストリームを作成しようとしています。私の springXD と HDFS は別のマシンにインストールされています** が、hadoop fs ls /コマンドを正常に起動できます。
ストリームを作成してデプロイした後、次を使用してデータを投稿すると:
エラーをスローしています：
http エンドポイント http://{ipaddressofhdfsmachine:8020} にデータを送信できませんでした
使用localhost with port 9000すると正常に完了しましたが、hdfsには何も表示されませんでした。
ストリームを作成するには、同じマシンに hdfs とスプリングが必要ですか?
spring-xd - Spring XD での負荷分散はどのように行われますか?
私は Sring Xd を分散モードで実行しており、いくつかの JMeter テストを実行し始めています。
私の質問は、生成された負荷が分散モードでコンテナー間でどのように分散されるかについてです。
100 人のユーザーに対してそれぞれ 1000 のメッセージを生成する場合、このトラフィックを実行中の 2 つ以上のコンテナー間で分割したいと考えています。
これは可能ですか？それとも、1 つのコンテナーがすべての負荷を引き受けますか? 私の現在のセットアップでは、これが起こっているようです。