python-asyncio

1熱

1答えて

今日私はPython（3.6）の新しいバージョンを使用しようとしました。私はaiopgをpip（PyCharmインタプリタセクションツール経由）でインストールしました。そして、私はaiopgをインポートしようとした後に、例外が起こった： from aiopg.sa import create_engine File "C:\Python36\lib\site-packages\aiop

2熱

1答えて

asyncioでシェルプロセスを管理する方法は？

デーモンの再起動プロセスをpythonのasyncioモジュールで追跡したいと思っています。ですから、シェルコマンドtail -f -n 0 /var/log/daemon.logを実行して、それを出力の解析をする必要があります。たとえば、service daemon restartをバックグラウンドで実行しています。デーモンは、サービス再起動コマンドの実行が終了して内部チェックであることを報告し

3熱

1答えて

C++はデキューからデキューへ要素を移動するときに2倍のメモリを使用します

私のプロジェクトでは、pybind11を使用してC++コードをPythonにバインドします。最近、私は非常に大きなデータセット（70GB +）に対処しなければならず、std::dequeのデータを複数に分割する必要が生じましたstd::deque。私のデータセットは非常に大きいので、私はスプリットがメモリオーバーヘッドの多くを持っていないと思っています。だから私は一般的に私の要件が満たされることを

0熱

1答えて

asyncioでタスクをスケジュールしたりキャンセルするには

私はクライアント/サーバアプリケーションを作成しています。接続されている間、クライアントはサーバに「ハートビート」信号、例えば毎秒を送信する。サーバ側では、タスク（またはコルーチンなど）を非同期に実行するためのメカニズムが必要です。さらに、 "ハートビート"信号の送信を停止したときに、クライアントからタスクを取り消したい。つまり、サーバーがタスクを開始するときには、タイムアウトの種類があるか、

1熱

1答えて

Pythonの非同期速度が関数に比べて

David BeazleyとYuri S.の両方は、今日私が見てきたいくつかのYouTube動画で、asyncは関数よりも2倍遅いと言います。私はこれを理解していない。非同期の全体点は並行性であるため、1つの関数が1つのコルーチンより高速であっても、ほとんど実世界の状況にはなりません。その代わりに、同時に複数のコルーチンを関数で同時に実行するのではなく、複数のコルーチンを同時に実行することになりま

1熱

1答えて

aiohttpタイムアウトが正しく機能しない

async_timeoutで（aiohttpを使用して）サイトにhttp-requestを行うコードがあります。すべてのリクエストを一緒に実行すると、TimeoutErrorが発生しているリクエストがあります（timeout = 20秒であっても）。しかし、私が1つのリクエストを実行すると、それは機能します。 def coro(url): with async_timeout.time

2熱

1答えて

ピラミッドビューのAsyncioサブプロセスの使用

ピラミッドビューでasyncioサブプロセスを実行しようとしていますが、ビューがハングし、非同期タスクが完了しないように見えます。私はピラミッドビューの外でこの例を実行することができ、それは動作します。それとは、私はもともとloop = asyncio.get_event_loop()を使用してテストしているが、これは、私は完全にここで理解していないものは確かにありますRuntimeError:

2熱

2答えて

socket.sendtoが非ブロック操作であると想定するのは安全でしょうか？

socket(AF_INET, SOCK_DGRAM)で作成したソケットオブジェクトをasyncioループで使用します。しかし、https://docs.python.org/3/library/asyncio-eventloop.html#low-level-socket-operationsにはsendtoの機能が見つかりませんでした。この関数はasyncioループ内で呼び出すことができるノ

1熱

1答えて

なぜcall_at_threadsafeとcall_later_threadsafeはありませんか？

私はWindows 32ビットでPython 3.5.2を使用しており、asyncio call_atはスレッドセーフではないことを認識しています。したがって、loop._write_to_self()という行のコメントを解除しない限り、次のコードは 'bomb' import asyncio import threading def bomb(loop): loop.call_

5熱

1答えて

ほとんどのasyncioの例でloop.run_until_complete（）を使用するのはなぜですか？

私はasyncioのPythonドキュメントを調べていましたが、ほとんどの例がAsyncio.ensure_future()ではなくloop.run_until_complete()を使用する理由が不思議です。例えば：https://docs.python.org/dev/library/asyncio-task.html ensure_futureが非ブロッキング機能の利点を実証するためのより