rabbitmq

    0熱

    2答えて

    rabbitmq複数の消費者および複数の出版社

    複数の出版社および消費者の行動を知りたい。 rabbitmqサーバーは、一度に消費者のいずれかに1つのメッセージを送信しますが、他の消費者はその時点で理想的ですか？ OR 時に、複数の消費者がキューからメッセージを消費しているように、消費者は、キューから任意の無人のメッセージを選びますか？ 基本的に私は、データベースキューを設計していますし、一度に複数の挿入を望んでいません。
    rabbitmq 2010-12-05

    8熱

    2答えて

    非同期キューモニタリングのためのPornでのTornadoの使用

    Tornado web serverに公開して読んでいるAMQPサーバ（RabbitMQ）があります。これを行うために、私は非同期のamqp Pythonライブラリを使用すると考えました。特にPika（おそらくトルネードをサポートしているバリエーション）。私はリクエストの終了時にことを除いて、成功したキューからの読み取りに見えるコードを書かれている が、私は例外を取得（ブラウザは罰金を返す）： [
    python asynchronous rabbitmq amqp tornado 2010-12-19

    10熱

    2答えて

    Celery/RabbitMQを永続化する方法はありますか？

    私のサーバーがクラッシュしても、私のタスクはまだありますか？
    database persistence queue rabbitmq celery 2010-12-28

    1熱

    3答えて

    どうして私のPythonコードがうまくいかないのですか？ celery.decoratorsから

    は私tasks.pyファイルのタスク from celery.decorators import task @task() def add(x, y): r = open("./abc.txt","w") r.write("sdf") r.close() return x + y をインポートします。 >>> import tasks >>> r
    python django file rabbitmq celery 2010-12-29

    0熱

    3答えて

    私のPythonコードに何か問題がありますか？ （関数）

    #tasks.py from celery.decorators import task @task() def add(x, y): add.delay(1, 9) return x + y >>> import tasks >>> res = tasks.add.delay(5, 2) >>> res.result() 7 このコードを実行すると、タス
    python django queue rabbitmq celery 2010-12-29

    0熱

    2答えて

    RabbitMQ：非ポーリング戦略を使用して複数のコンシューマを1つのキューに配置できますか？

    RabbitMQを使用して、1台のマシンのプロデューサから、複数のマシンに分散された小さなグループのコンシューマにジョブを送信します。 プロデューサはジョブを生成してキューに配置し、コンシューマは10ミリ秒ごとにキューをチェックして、要求されていないジョブがあるかどうかを確認し、ジョブが使用可能な場合は一度にジョブをフェッチします。ある特定のワーカーがジョブを処理するのに時間がかかりすぎると（GC
    message-queue messaging rabbitmq producer-consumer blackboard 2010-12-30

    0熱

    1答えて

    RabbitMQは一度だけキューからメッセージ数を取得する

    RabbitMqのキューからメッセージを取得しようとしていますが、最初にメッセージカウントを与えてからカウントを与えません。スカラ言語を使用しています。どんな種類の助けにも感謝します。 コード、それはそこに二度目に行くとき私のコードは、でCONN = FACTORY.newConnectionこのラインで無限ループになっている def act { loop { FACTORY = n
    scala rabbitmq actor 2010-11-18

    5熱

    2答えて

    RabbitMQからどのようにキューバインディングを削除しますか？

    RabbitMQを使用して、興味のある加入者にメッセージをトピック別にルーティングしています。各サブスクライバにはキューがあり、関心のあるトピックにキューをバインドします。ユーザーがトピックリストからアイテムを削除できるようにしたいと考えています。 私の設定では、バインドされたトピックをそのユーザーのキューから「バインド解除」する必要があります。 私はpyamqplibを使用していますが、チャネル
    rabbitmq amqp py-amqplib 2010-11-23

    1熱

    1答えて

    メッセージングとウェブサービスを分離する

    私はすぐに信頼性の高い、合理的に高いスループットのメッセージングを必要とするアプリケーションを構築します。しかし、私たちのメッセージのエンドポイント消費者の多くは、SOAP Webサービスです。 RabbitMQと関連技術は非常に魅力的です。アプリケーションからメッセージ配信を切り離し、再起動しても持続できる信頼性の高いメッセージキューイングシステムを提供します。これは非常に魅力的ですが、私が読ん
    web-services rabbitmq 2010-12-02

    1熱

    1答えて

    Rabbitmqキューからデータを読み取り、それをrubyを使ってデータベースに保存するための最善のアーキテクチャですか？

    私はprodアプリケーションからロギングのためにrabbitmqキューにデータをダンプしているプロジェクトに取り組んでいます。キューの反対側では、記録されたレコードをキューから取り出してdbに入れる必要があります。 キューの反対側で同じまたは類似のモデルクラスを使用したいので、データを記録するアプリケーションと、ログに記録されたデータを読み込んで保存するアプリケーションは、誰でも考えているのと同じ
    ruby-on-rails ruby rabbitmq 2010-12-03
最新の質問