kombu

1熱

1答えて

HAモードでクラスタに3つのRabbitMQノードがあります。各ノードは別々のDockerコンテナにあります。 CELERY = dict( broker_url=[ 'amqp://[email protected]:5672', 'amqp://[email protected]:5672', 'amqp://[email protected]:56

0熱

1答えて

rabbitmqのkombuでRPCクライアントを実装していて、直接返信する機能

kombuでウサギを使用するためのrpcフレームワークを実装しています rabbitmq's direct reply-to featureを使用したいが、kombuで実装する方法が見つからない。クライアントはメッセージを生成する前に 'amq.rabbitmq.reply-to'キューで消費する必要があり、プロデューサとコンシューマは同じチャネルを使用する必要があります。クライアントがスレッ

2熱

1答えて

セラーのアップグレード（3.1 - > 4.1） - ピアによる接続のリセット

昨年はセロリを使用していましたが、従業員は約15名で、1-4の並行性が定義されています。最近、私たちは今、私たちは労働者のログの各1は、そのようなエラーに発生する可能性がありますどのような任意のアイデアで、次のエラーを持っているV3.1からV4.1 に私たちのセロリをアップグレード？ところで 2017-08-21 18:33:19,780 94794 ERROR Control command

0熱

1答えて

Heroku：dbm.error：db typeはdbm.gnuですが、モジュールは利用できません

どのようにエラーを修正できますか？それはHerokuによってインストールされる必要があるように見えます。私はherokuに電子メールを送信してインストールする必要がありますか？それについて何もできませんか？ 2017-03-26T13:04:08.185159+00:00 heroku[beat.1]: Starting process with command `celery -A PROJEC

3熱

1答えて

Kombu + RabbitMQ：キューが空であるかどうかを調べる

アーキテクチャ DBレコードを持つシステムを考えてみましょう。各レコードはliveまたはexpiredのステータスになります。 liveレコードは、外部ソフトウェアモジュールを使用して定期的に処理する必要があります。私はKombuとRabbitMQの古典的なプロデューサ - コンシューマアーキテクチャを使用してこれを解決しました。プロデューサは数秒ごとにDBからレコードを取り出し、コンシューマが

0熱

1答えて

ImportError：名前OrderedDictをインポートできません。ダウングレードkombu

pythonを使用してIDL保存ファイルをプロットできるパッケージであるpytplotをインストールしてインポートしようとしています。 Windows 10にPython 2.7があります。pytplotをインポートしようとすると、次のようなインポートエラーが発生します。ImportError：名前OrderedDictをインポートできません。この質問はすでにGetting ImportError

0熱

1答えて

PythonからRabbitMQに接続できませんでした

私はPythonを学んでいます。私は奇妙な問題にぶつかります。私は私のmacOS SierraローカルボックスでRabitMQを実行しています。 PythonスクリプトからRabbitMQサーバーに接続すると常にソケットタイムアウトエラーが発生します。同時に私はtelnetで接続することができます。は、Python 2.7とライブラリ昆布を実行： # test.py from kombu im

0熱

1答えて

ユニットテスト用のメモリ内転送を正しく使用する方法

私はキューにメッセージを生成し、メッセージが正しく消費されてアプリケーションで処理されるかどうかを確認するためにいくつかのテストを作成しようとしています。私はkombuライブラリ、特にメモリ内のトランスポートの実装について試しています。まだ私はそれが働いて、生成されたメッセージが消費されることはありません。誰もが生成し、メモリ内のメッセージを消費し、簡単なユニットテストを提供できる場合私の質

3熱

1答えて

pytestで接続クラスを模擬してください

私は実際のrabbitmqサービスを実行することなくテストしたいと思っているkombu.ConsumerProducerMixinから継承するクラスを持っています。 from unittest.mock import Mock, patch from aggregator import Aggregator @patch('kombu.connection.Connection') de

0熱

1答えて

kombuから（u'json '、）のエンコーダがインストールされていません

私はどこかのステップを逃していると思いますが、私は見ていて、それを見つけることができませんでした。私のセロリの仕事を実行すると、私はget_task.delay(args)を呼び出すと、このエラーメッセージno encoder installed for (u'json',)がスローされます。私は私自身のカスタムシリアル化を持っていると思いますか？ settings.py CELERY_ACCEP