問題タブ [python-asyncio]

私は非常に怠け者であることを認めます。私はこれをかなり迅速に行う必要があり、Python3 asyncio モジュールについて理解できません。(面白いことに、ブースト 1 はかなり直感的であることがわかりました。)

時々ブロックするファイル オブジェクト (パイプ) を readline する必要があります。この間、ファイルから読み取るものがあるかどうかに関係なく、設定された間隔 (たとえば 30 分ごと) で別のアクティビティを起動できるようにしたいと考えています。

python3 asyncioを使用してこれを行うためのスケルトンを手伝ってくれる人はいますか? (twisted などのサードパーティ製モジュールをインストールできません。)

ピラミッド アプリケーションで 1 時間ごとにバックグラウンド ジョブを実行する必要があります。ジョブは、クライアントの要求に応答するメイン スレッドをブロックせずに非同期で動作します。このジョブは、店舗情報のデータベースにアクセスする必要があります。

これどうやってするの？どのライブラリ/パッケージ/アルゴリズムを使用する必要がありますか?

Debian 7 サーバー上の Python 3.4.2 で Asyncio に奇妙な問題が発生しています。クライアントから切断されたかどうかを検出しようとしています。Web 上のほとんどの例では、このメソッドを使用しています。応答を読み取って空の場合は、ループを中断して接続を閉じます。

ただし、正確に 9 回の反復の後、スクリプトは読み取り行で停止します。10 回の反復ごとにのみ読み取りを実行しようとしても、90 回の反復後に停止します。クライアントの切断を検出しようとしない場合、スクリプトは問題なく永久に実行されます。

元のコードは、この要点のサーバーに基づいていました: https://gist.github.com/dbehnke/9627160

これを引き起こしている可能性のあるアイデアはありますか？

(スクリプトが完成したので、実行して自分の目で確かめてください)

Python 3.4/Asyncio では、StreamReader/Writer を使用しています。

クライアントの切断を検出する一般的な方法は、クライアントから読み取ることであり、そこに何もない場合、クライアントは切断されているようです。

ただし、クライアントヘッダーから読み取る行がすぐに不足し（ループごとに次の行に移動します）、クライアントから追加の行が送信されない場合（私の場合、クライアントはリッスンするだけで送信していません）、タイムアウト。

私がやりたいのは、ヘッダーの最初の行だけを何度も読むことです..または、最初の行の最初の文字だけを読むこともできます.最初。

このタスクを達成するための最良/最もエレガントな方法は何ですか? 3.4/非同期/ストリームリーダー/ライター。(クライアント切断の検出)

zmq.Socket.send_multipartを介してノンブロッキング方式でデータを送信する場合、操作が失敗したかどうかはどのようにわかりますか? たとえば、私がデバッグしようとしているaiozmq ライブラリでは、次のようになります。

私のシナリオは、サーバーが zmq.Socket.send_multipart を介してデータを送信するというものですが、クライアントはそれを受信しないため、データの送信が単に失敗するかどうか疑問に思っています。