python-asyncio

1熱

1答えて

最後にwebsockets、asyncio、PyQt5を一緒に使用します。クマシュは必要ですか？

私は、PyQt5を使用するクライアントとasyncioの周りに構築されたwebsocketsモジュールで作業してきました。私は以下のコードのようなものが動作すると思ったが、私はラインの編集ボックスに入力をクリックするまで、（サーバーからの）着信データがGUIで更新されていないことがわかった。これらの着信メッセージは、GUIへの更新のためのパルスを設定するためのものであり、更新に使用されるデータを運

python-3.x websocket pyqt5 python-asyncio 2017-09-25

---

0熱

1答えて

unittest.mock.patchでaiohttpクライアントをテストする

私はaiohttpを使って簡単なHTTPクライアントを作成しましたが、aiohttp.ClientSessionとaiohttp.ClientResponseにパッチを当ててテストしようとしています。しかし、あたかもunittest.mock.patchデコレータが私の非同期コードを尊重していないかのように見えます。推測すると、私はそれが何らかの名前空間の不一致であると言います。ここで は、最小限

python testing patch python-asyncio aiohttp 2017-09-27

---

2熱

1答えて

asyncioタスクでCancelledErrorを無視する方法

クライアントが接続を閉じると、asyncioタスクがCancelledErrorを受信し、要求処理が停止します。すべてのタスクを終了し、接続エラーを無視する方法はありますか？

python-asyncio 2017-10-12

---

0熱

1答えて

テストのpython asyncioコルーチンは、私は、プラグインasyncio pytestと、次のメソッドをテストしようとしています例外TypeError

を提起 class TestController(object): @pytest.mark.asyncio async def test_get_item(self): controller = Controller() item = await controller.get_item('item-1') assert item.get

python python-3.x testing python-asyncio 2017-10-15

---

3熱

1答えて

asyncioのカスタムトランスポートを作成する方法は？

私はProtocolとTransportクラスのドキュメントをasyncioパッケージで読んでいます。具体的には： プロトコルクラスをサブクラス化するときは、特定のメソッドをオーバーライドすることをお勧めします。これらのメソッドはコールバックです。特定のイベントで転送によって呼び出されます（たとえば、データが受信されたときなど）。トランスポートを実装している場合を除いて、に電話をしてはいけません。

python python-asyncio 2017-10-16

---

3熱

1答えて

Pythonのrun_in_executorメソッド呼び出しで例外をキャッチする方法

run_in_executorで呼び出されたrun_long_thing（）関数で例外を発生させるにはどうすればよいですか？ 飲み込まれているようです。私は、ブロッキングコードの関数の結果は必要ありません。それは基本的に火災で、機能を忘れて、それでも私はいずれかが存在する場合、例外をキャッチする必要があります...すべての import asyncio import time def fi

python python-3.x exception asynchronous python-asyncio 2017-10-16

---

1熱

1答えて

非同期イテレータのタイプは何ですか？

例（質問は以下の）： import asyncio import typing as t from aiokafka import AIOKafkaConsumer class KafkaSimpleClient: ... async def receive(self, topic: str) -> ???: bootstrap_servers =

python python-asyncio typing 2017-10-17

---

0熱

1答えて

StreamReader.readexactly（）はソケットエラーを引き起こしますが、StreamReader.read（）を引き起こさないのはなぜですか？

私はネットワーク上でAsyncioを使ってPythonでアプリケーションを書いています。 try: data = await self._reader.readexactly(10000) # Code that uses data except IncompleteReadError as e: data = e.parial # More code

python sockets python-asyncio 2017-10-18

---

1熱

1答えて

python 3.6とValueError：ループ引数は将来一致する必要があります

私はちょうど簡単なテスト例を実行したいのですが、私は以下のエラーを受け取ります。どのように解決するのですか？ import asyncio import uvloop import concurrent.futures import time asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) async def do_som

python python-3.6 python-asyncio 2017-10-18

---