gevent

0熱

1答えて

Flaskとgeventを持つWebsocketerverをPythonで実装する

私はFlaskとgeventを持つWebSocketServerを持っています。私はWebSocketApplicationから継承した自分自身のWebsocketApplicationを持っています。このWebSocketApplicationでは、on_open(), on_close(), on_message()を上書きして正常に動作しています。また、すべてのクライアントにメッセージを送信

0熱

1答えて

gevent：タイムアウト前にI/Oが完了しますが、タイムアウトが発生します。

私は2つのグリーンレットを持っています。最初のグリーンレットは7秒間のタイムアウトを開始してから、HTTPリクエストを終了するまでに5秒かかります。 2番目のグリーンレットは完了するまでに10秒かかるいくつかのCPUバウンドタスク（time.sleepでシミュレート）を実行しています。コード：私はこのコードを実行すると from gevent import monkey; monkey.patch

5熱

1答えて

imapとgrequestsライブラリのマップ

mapとの違いは、mapはすべてのリクエストが完了するのを待ってから、注文データを返します。 imapはすぐにデータを返し、より少ない注文を出します。私が使用： urls = [...some_data...] rs = (grequests.get(u,, hooks=dict(response=callback_f)) for u in urls) r = grequests.map(r

1熱

1答えて

Django plus Cソケットモジュールのスレッディング付きCelery/RabbitMQ

Celery 4.xを使用してタスクを非同期で実行するDjango webappがあります。主なタスクでは、Django/Celeryコードが20〜100台の他のサーバーとのネットワーク通信操作を実行する必要があります。これらの他のサーバーに送信するリクエストはすべて同じです。つまり、ユーザーはDjangoにコマンドを送信します.Djangoは、Celeryに20-100のサーバーのそれぞれにまっ

0熱

1答えて

sslを持つPython Gevent Pywsgiサーバ

フラスコアプリをラップするのにgevent.pywsgi.WSGIServerを使用しようとしています。しかし、すべてうまくいきますが、sslの鍵と証明書を追加しようとすると、もはやクライアントを受け入れることさえできなくなります。これは、エラーがスローされます簡単な例である：これはエラーのスタックトレースです from gevent.pywsgi import WSGIServer from

0熱

1答えて

マルチプロセスのキューがgeventとうまく動作しません

マルチプロセッサとgeventを持つプロデューサとワーカーのワークフローです。私はプロセス間でマルチプロセスのキューといくつかのデータを共有したい。同時に、geventプロデューサとワーカーはデータを取得し、タスクをキューに配置します。 task1_producerはいくつかのデータを生成し、それをq1に入れます。 task1_workerはタスクq1のデータをcomsumeし、生成したデータをq

0熱

2答えて

サーバからログアウトしたときにAJAXリクエストがgunicornで正常に動作しない

私は今週末に初めてのdjangoアプリケーションをサーバーにデプロイしました。私はPostgreSQL、PostGIS、virtualenvなどをインストールしなければならなかったので、それは明確なVPSサーバーでした。アプリケーションを作成するには時間がかかります。 django開発サーバーでは問題なく動作しますが、VPSサーバー上でAJAXリクエストが正常に動作しない場合は、gunicorn（

0熱

1答えて

ジエント互換リエントラントロック？

geventのRLockに相当するものは何ですか？同等のものがない場合は、現在のグリーンレットを特定して実装することができますか？ソースを読むことから、gevent.lock.BoundedSemaphore(1)は、単純な（リエントラントでない）ロックに相当します。テストでもこれが示されます。