問題タブ [cloudamqp]

ホストされたRabbitMQプロバイダー、つまりCloudAMQPを使用し、herokuでdjangoアプリサーバーを実行しています。ローカル環境ではすべて正常に動作しているように見えますが、CloudAMQP がブローカーへの同時接続数に制限を設けている Heroku では、接続が永久に持続するように見え、最終的にアプリで使用可能なオープン接続が不足します。これは、以前の接続に関連付けられたタスクがサブスクライバー (つまり、heroku ワーカー) によって実行された場合でも発生します。

CloudAMQP を Heroku と django celery で正常に使用できた場合は、うまくいったことを投稿できますか?

Celery のドキュメントでは監視に flower を使用することを推奨しているため、ホストされている RabbitMQ プロバイダー (CloudAMQP) と連携させようとしています。

以下に示すように、CloudAMQP 管理コンソールに 500 Internal Server エラーが表示されます。これは、何も持っていないのにパスワード エラーを示しているようです。

では、cloudamqp を使用してセロリを監視するにはどうすればよいでしょうか。

そして、これに対するより良い解決策（監視/タスクキュー）はありますか?

MT サービス バスの初期化コードは次のようになります。

アプリの設定は次のように設定されています。

CloudAMQPの管理サイトに my_queue という名前のキューが作成されます。

nuget の MT v2.8.0 を使用しています。ローカル PC と AppHarbor サイトの両方からこれを実行しようとしましたが、どちらも例外をスローしました。

アプリの設定値を変更して、RabbitMQ のローカル インストール ( rabbitmq://localhost/my_queue ) を指すようにすると、すべて正常に動作します。

私は何か間違ったことをしていますか？アドバイスをいただければ幸いです。

前もって感謝します。

For some time now I'm trying to create topic consumer that will not require subscription. So i would like to achieve similar behavior like with JMS non-durable topic subscriber.

I'm using MS Azure AMQP 1.0 service bus and apache qpid amqp 1.0 client (JMS implementation).

Thanks

Django アプリケーションがあり、非同期タスクに Celery を使用しています。さらに、RabbitMQ をローカルで使用していますが、Heroku では CloudAMQP プラグインをセットアップしようとしています。アプリケーションはエラーなしで開始されますが、Celeryに送信されたタスクは次のエラーで失敗します。

呼び出し中に失敗する単純なタスクがあります。

heroku のログは次のとおりです。

settings.py の一部:

前もって感謝します。