pyzmq

5熱

1答えて

pythonでIPCの効率的なソリューションを探すときにzeromqを見つけました。私はいくつかのCPUを集中処理する必要があるいくつかのPythonプロセスをマスタープロセスのdictからのデータに持っています。これらのワーカープロセスはdictからのみ読み込みますが、マスタープロセスだけがdictを変更することができます。 dictのデータは変更されますが、マスタープロセスを介して原子的に変更

0熱

1答えて

async zmqでキーボード割り込みを処理する

asyncioを使用して、pyzmqのZeroMQサーバーを作成しています。私は正常にサーバーの停止を処理しようとしていますが、非同期モジュールに関するドキュメントはほとんどなく、現在のポーリング/待機を処理する簡単な方法ではないようです。 .stopメソッドでループを停止することはあまり効果がなく、実際には終了しません。それが実行しているとき、私は優雅にこれをどのように停止しない daemon

1熱

1答えて

pyzmq "--with-pgm"のインストール方法

私のマシンにはzmqバージョン4.1.3とpyzmqバージョン15.2.0がインストールされています（私はpip経由ですが、今は覚えていません）。 UDP epgmソケットに接続する必要がありますが、 "プロトコルはサポートされていません"というエラーが表示されます。私はインターネットの広大な広がりを探して答えを見つけました： "--with-pgmオプションでゼロmqを構築する"。誰でもその方

0熱

1答えて

ipyparallelが "registration：stalled registrationをパージする"を表示しています

ipiparallelライブラリを使用して、異なるマシン上でipcontrollerとipengineを実行しようとしています。私のセットアップは次のとおりです。リモートマシン：のWindows Server 2012 R2 x64の、ポート5900およびIP = 0.0.0.0をリッスンし、ipcontrollerを実行しています。ローカルマシン：のWindows 10のx64、ipe

1熱

1答えて

ZMQ：複数の同時リクエストとポーリングでREQ/REPが失敗する

ZeroMQで奇妙な動作が発生しましたが、私は今一日中デバッグしようとしています。問題を再現する最小限のスクリプト例です。これはPython3で実行できます。 REPソケットを持つ1台のサーバが起動し、REPソケット付きの5台のクライアントが基本的に同時に接続します。その結果、最初のいくつかのメッセージの後に何らかの理由でサーバーがブロックされ始めます。 poller.poll(1000)は無期

1熱

1答えて

aiohttpウェブサービスでZMQが「ランダムに」クラッシュする

は、ZMQを使用してジョブを作業者に送信し、結果を待つaiohttpベースのWebサービスがあります。もちろん、ZMQイベントループを使用していますので、ZMQソケットを待つことができます。私はちょうど私のテストマシン上でそれを実行した場合のコードは、正常に動作していること、「ときどき」 ... await socket.send(z, flags=flags) File "/usr/loca

0熱

1答えて

pyzmq for Windowsのインストールでエラーが発生するC2143、C4142

私はpython 2.7のWindows 7マシンを持っており、theseステップの後にpyzmqをインストールしようとしています。私はlibzmqをビルドして、libzmq\bin\Win32\Debug\v140\dynamic\からlibzmq\lib\にコピーしました。次のステップがうまくいくので、コンパイラは/ libと/ includeを同じ親フォルダからアクセスできます。しかし、この

6熱

1答えて

ZeroMQ PubSubが動作しないw \ Pyzmq

おそらく紛失しているものがありますが、公式のPyzmqパッケージ（https://github.com/zeromq/pyzmq）を使用してPythonで動作する単純なpub-subの例は得られません。私は最新のZeroMQ安定版リリース4.0.3を使用しています。簡単な例をcで簡単に手に入れることができます。私はMacとUbuntuマシンの両方で試しました。あなたが起動すると仮定すると sub

2熱

1答えて

zmqサブスクライバで自動再接続

私は時々すべての加入者にいくつかのメッセージを送るサーバを持っています。一言で言えば、たぶん1ヶ月に1つです。たぶん1日に100を送る必要があり、それ以降はもっと送ることなく数ヶ月を費やすでしょう。しかし、私はそれができるようにする必要があります。これまでは、Pythonでパブリッシャを持っていて、フレームとサブスクライバをPythonでも各エンドデバイスに送りました。最後のデバイスのスクリプト

0熱

1答えて

Python 2.7とPython 3.5の間でPYZMQがメッセージを受信しない

python 2.7とpython 3.5の間のバイト配列とstrの型がpyzmq PUB/SUBの問題であるようです。私はpython 2.7とpython 3.5の中の1つをpub/sub brokerにする必要があります。両方のpub/subブローカーに加入しているが、発行されたすべてのメッセージを受信していないサブスクライバーがあります。 pub/subブローカーに登録してそこに公