問題タブ [amqp]

さらに、その JSON のサイズを 5MB にすることは可能ですか?

なぜどちらか一方を使用するのですか？

多くの場合、私のキューは空のままになります。しかし、いっぱいになった場合、そのキューはどのようにしてサーバーにPythonスクリプトを実行するように通知しますか？

Pythonスクリプトが5秒ごとにキューにヒットするようにすることもできますが、それはばかげています。

適度なユーザー同時実行性を処理する必要のあるWebベースの生産性アプリケーションを構築しており、サーバーとクライアント間でデータの同期を維持するためのさまざまなオプションを検討してきました。アプリケーションデータはページの読み込み時にJavaScriptにブートストラップされ、WebSocketはデータをサーバーにプッシュするために使用されます。

少しコンテキストとして、私は現在Node.JSとSocket.IOを使用して、Djangoバックエンドへのプロキシとして機能する永続的なクライアントサーバーゲートウェイを作成しています。

課題は、接続されているすべてのクライアントを相互に同期させて、1つのクライアントセッションでのアプリケーションへの変更が、接続されているすべてのクライアントセッションにすぐに反映されるようにすることです。難しいのは、必ずしもすべてのユーザーがすべてのデータを表示できるわけではないということです。さまざまなユーザーレベルがあり、ユーザーごとにわずかに異なるデータセットの所有権を取得できます。

したがって、オブジェクトが何らかの方法で変更され、その変更がデータベースにコミットされる場合、現在接続しているユーザーのどのユーザーにデータを安全にプッシュできるかを知る必要があります。

私はこれに対するさまざまな解決策を模索してきましたが、これはpubsubメッセージングキューを介して処理できるもののように感じます-AMQPのようなものを使用しますが、アプリケーションの構造を理解するのに苦労しています。

私の頭の中では、アプリケーションの構造は次のようになります。

Client<-> Node.JS gateway<-> AMQP messaging queue<->Django app

Node.jsインスタンスとDjangoインスタンスを単一のクライアントとして扱い、単一の直接交換を作成してから、Node.jsで結果をフィルタリングする必要がありますか？

または、この種のフィルタリングは、メッセージングシステムが処理できるものであり、たとえば、接続されている各クライアントが関連するトピックにサブスクライブし、表示が許可されているデータのみを受信しますか？

メッセージングシステムの使用経験がほとんどないため、アプリケーション内でどのような役割を果たせるかを頭に入れておくのに苦労しています。アドバイスをいただければ幸いです。

RabbitMQを使用して、トピックごとに関心のあるサブスクライバーにメッセージをルーティングしています。各サブスクライバーにはキューがあり、関心のあるトピックにキューをバインドします。ユーザーがトピックリストからアイテムを削除できるようにします。

私の設定では、そのユーザーのキューからバインドされたトピックを「バインド解除」する必要があります。

pyamqplibを使用していますが、チャネルオブジェクトを介してこれを行う方法がわかりません。以前にバインドされたルーティングキーをキューから削除する方法はありますか？

再起動されたRabbitMQサーバー交換でキューを検出できるpythonクライアントが必要であり、クライアントを起動して各キューからのメッセージの消費を再開します。RabbitMQ 互換の python api/library からキューを検出するにはどうすればよいですか?

通常、私はbeanstalkcに文字列を入れることに慣れています。しかし、私は辞書を仕事としてamqpに入れたいと思います。

Udiはここで、「人々はNServiceBusのMSMQレイヤーを交換し、代わりにRabbitMQをプラグインした」と述べています。

AMQPを使用するMono/LinuxでNServiceBusを使用して構築されたアプリを実行できるようにすることを最終目標として、同じことを実行したいと考えています。

飛び込む前に、避けるべき落とし穴や赤いニシンなどについて、すでにこれを行っている可能性のある人々からフィードバックをもらいたいと思います。

あるいは、アプローチが大規模な作業である場合は、RabbitMQを直接使用するのが最善かもしれませんが、可能であればNServiceBusを使い続けたいと思います。

プロジェクトの 1 つで django セロリを使用していますが、(13、許可が拒否されました) エラーが発生します。

トレースバックについては、以下を参照してください。

許可と関係があると思います。サーバーへのログイン資格情報は問題ありません。これ以外はすべて機能します。

celeryd デーモンは、指定した rabbitmq 接続資格情報で正常に動作します。

開発サーバーをルートとして実行すると、このエラーは発生しません。ファイルまたはソケットのアクセス許可に関係があるのではないかと思いますが、どこで修正すればよいかわかりません。

RabbitMQ サイトに PHP クライアントのリストがあります。これらのいずれかを使用したことがある人がここで経験を共有できることを期待して、この質問をしています. 例えば

• インストールに問題はありませんでしたか？
• 安定していますか？
• パフォーマンスの問題はありましたか?
• ドキュメント/サポートはどうですか?

これらのライブラリのいずれかを使用したことがある場合でも、経験を共有してください。

参考までに、リストされているクライアントの一部を次に示します。

• AMQP の PHP マニュアル ページ
• php-amqp - StudiVZ によって開発および使用されるクライアントで、元々は RabbitMQ-C に基づいていました
• php-amqplib py-amqplib のポート
• php-amqplib PHP 5.3 をサポートするように更新された php-amqplib のフォーク
• AMQP クライアントの PECL リリース

PS「最高...」が「主観的」であることは知っていますが、この質問のポイントは、経験を収集し、人々がこれらの AMQP ライブラリについて十分な情報に基づいた決定を下せるようにすることです。「最高」という言葉が含まれているという理由だけで、この質問を急いで閉じないでください。

PPS RHEL 5 で PHP 5.3 を使用しています。