問題タブ [gevent]

新しいPython AMQPライブラリPuka（Pikaと混同しないでください）について読んでいて、イベントループを処理する方法がgeventまたはeventletと互換性があるかどうか疑問に思っていました。私の限られた知識に基づくと、gevent/eventlet で自動的にパッチを適用できるようです。

ありがとう！

ソース: http://github.com/majek/puka

ドキュメント: http://majek.github.com/puka/puka.html

私が今持っているよりも pymongo に関するより多くのドメインの専門知識が必要なここで急ごしらえ:

gevent monkey_patch() を呼び出して、gevent の「非同期」グリーンレット内で r/w での pymongo のブロック動作を正常に変更するために、Python で記述された pymongo ドライバーの「正しい」部分はありますか?

これが gevent と pymongo でもう少し足を運ぶ必要がある場合 - しかしそれは実行可能です - irc について少しのガイダンスを得ることができる限り、私は喜んで時間を割きます.

ありがとう！

注: 小規模な mongo 書き込みでは、ブロックを解除する前に書き込みの「リクエスト」をキューに入れるだけなので、大きな問題にはなりません。しかし、彼のねじれた非同期 mongo ドライバー (https://github.com/fiorix/mongo-async-python-driver) について fiorix と話していると、mongo のクイック書き込み (リクエスト) でさえ、大規模な非同期アプリケーションで問題を引き起こす可能性があります。(そしてもちろん、ノンブロッキング読み取りは最初から問題を引き起こす可能性があります!)

問題はプロキシ プログラムで発生しました。G10K を考慮して、プログラムで gevent を使用し、低レベルの gevent.core を使用してすべての機能を実行しています。

プログラムを複数のプロセスに変更する前に。全て大丈夫。しかし、それを変更すると、問題が発生します。

問題は、プロセス NO.2がソケットを受け入れると、プロセス NO.1 のイベントがディスパッチを停止することです。そして、イベントに sleep(0.1) を追加すると、驚きました。しかし、スリープ時間を短くすると、問題が再び発生しました。

この問題は 1 週間私を悩ませましたが、まだそれとは何の関係もありません。誰か助けてくれませんか?

私はそのようなイベントを使用します:

ZeroMQ を gevent ループに接続したい。ZeroMQ API を使用して、ソケットの fd を取得できます。他の greenlet をブロックせずに、greenlet で POLLIN イベントのこのソケットを監視するにはどうすればよいですか?

ほとんどの場合、を使用するgevent.event.Eventと、コードは次のようになります。

リスナーは次のようになります。

これは「それを行う正しい方法」ですか？または、定期的なイベントを複数のリスナーに通知するためのより良い方法はありますか？

gevent-websocketを機能させようとしていて、フラッシュ仕様のポリシーサーバーに接続していません。私のpolicy.pyは次のとおりです。

しかし、WebSocketを使用すると、次のようになります。

Pythonでバイト配列（Javaのbyte []のように）を表現するにはどうすればよいですか？geventを使って有線で送信する必要があります。

次のコード (ここから取得: https://bitbucket.org/denis/gevent/src/6c710e8ae58b/examples/wsgiserver_ssl.py ) は、非常に高速な greenlet を利用した wsgi Web サーバーを実装します。

ただし、これは 1 つのコアでのみ実行されます。複数のプロセスを利用するには、これをどのように変更しますか? ガンコーンを含む答えを探しているのではなく、もっと単純なものを探しています。

ヒント

gevent と multiprocessing を使用したコード サンプルを次に示しますが、これを WSGI で機能させる方法がまだわかりません ( https://gist.github.com/1169975から取得)。

geventとflask、または非同期サーバーとしてtornadoを使用したflaskを使用して、一般的なsocket.io接続（クライアントブラウザーに依存し、websockets、またはxhr-longpollingなど）を処理する方法の例を誰かに見せてもらえますかありがとうございました

このコードのどこが間違っているか知っている人はいますか? それは単に永久に「ロード」されます。出力なし。「Sites」は、数十個の文字列のリストです。