問題タブ [carrot]

Ruby AMQP Carrot ライブラリを使用しており、仮想マシンでテスト用の RabbitMQ サーバーと通信しようとしています。マシンで AMQP ポートが開いていますが、Carrot で外部接続を確立できません。私は次のことを試しました：

Carrot.queue('message', :durable => true, :server => '192.168.162.176')

Carrot.queue('message', :durable => true, :host => '192.168.162.176')

Railsでシングルトンを初期化するのに最適な場所はどこですか？

Ruby onRailsアプリでCarrotAMQPライブラリを使用していますが、生成されるすべてのタスクではなく、一度だけ設定を初期化したいです。

私は現在environment.rbにそれを持っており、それは機能しているようですが、これが最良の場所であるかどうかは完全にはわかりません。

Railsが起動した後でのみCarrotを初期化するのは良い考えですか、それとも作成されるすべてのタスクに対して新しいCarrotオブジェクトを作成する必要がありますか？

Python プロジェクトで Carrot を使用しています。メッセージ キューのコンシューマーとして機能する Python スクリプトを作成しました。Windows 7 のコマンド ライン シェルを使用して、この Python スクリプトを次のように呼び出しました。

ただし、しばらくすると、実行中のセッションが中止され、エラーは次のようになります。

プロデューサー セッションは、Linux サーバーで引き続き正常に実行されています。どうすればこれを修正し、 Windows で消費者セッションを長時間実行できるのでしょうか。

昆布を使って他のデータと一緒にファイルを送るにはどうすればいいですか？ブローカーとしてrabbitmqを使用しています。

例：辞書に沿ったfile.pdf {'author'：'user'}

可能であれば、これを1つのメッセージで行いたいと思います。しかし、昆布の標準的なシリアライザーを使用するとしたら、個別のメッセージをどのようにバインドしますか？

Celery を使用して、複数のデータ マイニング タスクを処理しています。これらのタスクの 1 つは、ユーザーごとに最大 10 の同時接続を許可するリモート サービスに接続します(つまり、グローバルに 10 接続を超えることはできますが、個々のジョブごとに 10 接続を超えることはできません)。

Token Bucket (レート制限)を探していると思いますが、その実装が見つからないようです。

(不完全に) クラスター化された文字列データがあり、1 つのクラスター内のアイテムは次のようになります。

最適なタイトルは「黄色の熟したバナナ」です。

現在、SQL GROUP BY を使用して、単純なヒューリスティックを使用しています。私のデータにはそのようなクラスターが大量に含まれており、それらは頻繁に変更され、新しい果物がクラスターに追加またはクラスターから削除されるたびに、クラスターのタイトルを再計算する必要があります。

改善したいのは以下の2点です。

(1)効率- たとえば、新しい果物の名前をクラスターのタイトルのみと比較し、毎回すべての果物のタイトルのグループ化/フレーズ クラスター化を回避します。

(2)精度- 最も一般的な完全な名前を探す代わりに、最も一般的なフレーズを抽出したいと考えています。現在のアルゴリズムは、2 回繰り返され、最も一般的な完全なフレーズである「Yellowripe」を選択します。ただし、「黄色の熟したバナナ」というフレーズは、特定のセットで最も一般的です。

Solr + Carrot2 を使用することを考えています (2 番目の経験はありません)。この時点で、文書をクラスター化する必要はありません。文書は他のパラメーターに基づいて既にクラスター化されています。中心となるフレーズをクラスターの中心/タイトルとして選択するだけで済みます。

任意の入力は非常に高く評価されています, ありがとう!

Heroku には 2 つのプロセス タイプがあります。Ruby の Web dyno と Node.js のワーカーです。Ruby から Node.js にメッセージを渡すために、RabbitMQ アドオン (現在はベータ版) を使用しています。Node は正しく接続して消費し、Ruby はキューを最初に接続/作成する限り、正しく接続して発行します。

どうやら、既に存在するキューを作成しようとすると、Carrot はいくつかの面白いエラーをスローするようです。これが、メッセージを送信できない理由 (昨夜テストしたときに機能していた可能性があること) を発見した方法です。 Ruby の前に Node プロセスを開始しました。

私は Heroku を使用しているので、Ruby と Node の各スレッドを複数同時に動作させることになり、それぞれが最初にキューを開始して既存のキューに接続することを問題なくサポートする必要があります。

それは私の質問に私をもたらします:

Ruby を使用して既存の RabbitMQ キューに接続し、既に接続されてメッセージの受信を待機しているコンシューマーにメッセージを発行するにはどうすればよいですか?

さて、私はPythonに不慣れで、この問題を調査していますが、そのようなものが見つからないため、何が起こっているのかわかりません。

私はセージを含むプログラムを作成していますが、メッセージキューがあります。これは開発マシン上にセットアップされているので、動作することはわかっていますが、すべてがどのように動作するかをよりよく理解し、自分で開発しやすくするために、自分のコンピューターにセットアップしたいと考えていました。

sageを起動するには、sagesのメインバイナリファイルを呼び出して実行可能な.pyファイルを渡すスクリプトを実行します。（./sage/sage ./sage_server.py）これにより、sage_server.pyファイルにエラーが作成されます。

しかし、ターミナル（./sage_server）でそのファイルを実行すると、インポートは正常に機能し、sageから何かをインポートしようとしたときにエラーが発生するのは27行目までです。

他の人から呼び出されたときにエラーが発生する原因を誰かが知っていますか？私はこれを引き起こしているものについて非常に迷っています。

rabbitmq サーバーに接続しようとしています。私は使っている

このエラーが発生しています

サーバーがダウンしているかどうかを確認するにはどうすればよいですか? どうすれば再起動できますか？

ruby でメッセージを公開するためにキャロット ジェムを使用しています。サンプル コードは次のとおりです。

コード :

ルーティング キーを使用して同じデータを公開する方法を教えてください。