問題タブ [nsq]

このエラーは次の場所で発生しますpynsq 0.4.2

スタックトレース

コード

最後の「トポロジ パターン」の例で説明した「NSQ リアルタイム分散メッセージング プラットフォーム」をDockerで複製することは可能ですか? dockerfile またはイメージの例を持っている人はいますか?

ELK スタックのブローカーとして nsq を使用しようとしています。

REST API経由でnsqにelasticsearchにデータを送信させることでこれを行うことを考えていました。そのドキュメントによると、HTTP PUT リクエストを作成してエラスティック サーチにデータを追加できます。

しかし、nsq docによると、nsqは nsq_to_http ユーティリティを介してのみ POST または GET 要求を行うことができます。Elasticsearch が必要とする PUT リクエストを作成できません。nsq から Elasticsearch に値を渡すにはどうすればよいですか?

これら2つのドッカーコンテナを接続しようとしています:

nsqd: https://registry.hub.docker.com/u/mreiferson/nsqlookupd/ nsqlookupd: https://registry.hub.docker.com/u/mreiferson/nsqlookupd/

これらは、nsqd および nsqlookupd の公式 Docker コンテナです。

問題は、nsqd でトピックを作成すると、そのトピックが nsqlookupd に表示されないことです。

すなわち

次のように 2 つのコンテナーを開始します (172.17.42.1 は Docker ホスト IP です)。

私は明らかに2つのコンテナを間違って接続しています。それらを適切に接続するにはどうすればよいですか？

ここでは一種の初心者ですが、例や助けがどこにも見つからないようです。私は NSQ の作業インスタンスを持っており、タスクやコンシューマーなどを登録できます。残念ながら、最初はシステムをセットアップしていませんでした。私がやろうとしているのは、NSQ が提供する組み込みのコマンド ライン ツール (nsq_to_file、nsq_tail など) をアクティブにする方法を見つけることです。それらを起動する方法に関するドキュメントを見つけましたが、どこから起動するかわかりません。

試してみるとnsq_tail --channel=MyTestChannel --topic=test --lookupd-http-address=127.0.0.1:4161、nsq_tail コマンドが見つかりません。私が知っている他の唯一のことは、NSQ が私たちの状況では docker によって管理されているということです。どんな助けでも正しい方向への押し込みは素晴らしいでしょう. ありがとう！

nsq src コードをダウンロードしてビルドしました。intellij 14.0 golang プラグインで src コードをナビゲートしたいと思います。エラーなしで nsq プロジェクト全体を intellij にインポートするにはどうすればよいですか?

私は Node の世界から来た Go 初心者で、公式の Bitly Go クライアントを使用してコンシューマを構築しています。AddConcurrentHandlers を使用して 50 のゴルーチンを生成し、メッセージの消防ホースを処理しています。問題は、コンシューマーが遅れて、未処理/受信メッセージの指数関数を nsq に残すことです。他の誰かがこれに遭遇しましたか？

サーバーまたは NSQ の構成に問題があるかどうか、およびすべてのメッセージを受信と同時に処理できるかどうかを確認するために、Node で同じものを構築しました。

行くコード: