python-asyncio

0熱

1答えて

異なるスレッドでコルーチンループを実行する

streamSimulationを2スレッド間で4回に分けて呼び出すことにします。 2番目のループを作成し、2番目のスレッドを作成してそのスレッドでループを実行するにはどうすればよいですか？ import asyncio import functools from concurrent.futures import ThreadPoolExecutor async def streamS

python multithreading python-multithreading python-asyncio 2017-11-20

---

2熱

1答えて

AWS IoT Python SDKとasyncio

AWS IoT MQTTサービスを使用する必要があります。私は現在https://github.com/aws/aws-iot-device-sdk-pythonで実験しています。 私のアプリケーションはWebソケットを使用して別のサービスと通信し、MQTTトピックをパブリッシュ/サブスクライブしてメッセージを転送/受信します。 このライブラリがコード実行をブロックする可能性はありますか？私はまだ

python amazon-web-services mqtt python-asyncio aws-iot 2017-11-21

---

2熱

1答えて

このループを非同期にする方法は？私は今のGitHub APIで働いている、とここにすべてがリスト内の各レポの要求を引っ張るフェッチ機能だ

： async def get_all_pulls(repos, api): pulls = [] for repo in repos: try: async for pull in api.getiter(f'/repos/{org}/{repo}/pulls?state=all'): pull['repo'] = repo

python-3.x asynchronous python-asyncio 2017-11-21

---

1熱

1答えて

asyncio.wait_for（）にタイムアウトが必要なのはなぜですか？

以下は、2つのバックグラウンドタスクを実行する単純なasyncioループです。 これらは両方とも単純なカウントを実行します。最初のものは永遠にカウントされ、 try/exceptで囲まれています。 2番目は5までカウントし、最初の1つをキャンセルし、 はループを停止します。 キャンセルが完了していることを確実にすることの2つの方法があります - asyncio.wait([a sequence o

python python-asyncio 2017-11-24

---

3熱

1答えて

python asyncioの "<Handle <TaskWakeupMethWrapper ..."という警告は何を意味しますか？

asyncioの将来の結果を設定している間、以下のメッセージが出力されています。 Executing <Handle <TaskWakeupMethWrapper object at 0x7fc3435141f8>(<Future finis...ection.py:260>) created at /media/stuff/stuff/projects/dare/dcds/dcds/common

python future python-asyncio 2017-11-24

---

1熱

1答えて

スレッドとasyncio：タスクは破棄されましたが保留中です

私はasyncioループを実行するスレッドを持っています。私はここで無関係なことをする将来の仕事を始める。スレッドを停止すると、asyncioループも停止します。それは出力実行 from contextlib import suppress from threading import Thread from time import sleep import asyncio class

python-3.x python-multithreading python-asyncio 2017-11-27

---

1熱

1答えて

aiohttp websocketのための自動接続

私はwebsocket接続を聞いて、まれなREST要求をするアプリケーションを書いています。 aiohttpはこれのための自然な選択のように思えますが、私は柔軟です。このアプリはシンプルですが、信頼性が必要です（データ損失を最小限に抑えながら、毎日収集するデータのギガバイト）。 aiohttpで接続損失を処理する最善の方法は何ですか？他のいくつかのPythonライブラリには、自動再接続オプションが

python-3.x websocket python-asyncio aiohttp 2017-12-03

---

1熱

1答えて

Asyncio from Python C-エクステンション

私は、ソケットからデータを取得して処理するPython C-エクステンションを持っています。処理中にGILを解放します。現在、私は2つのPythonスレッドを使用しています。その2つのCPUコアに90％の負荷がかかり、結果的にGILを解放するためにうまく絡み合っています。 私はPython 3 asyncioでどのように同じことを達成できますか？ 私は正しいPython-C-APIコマンドを見つけ

python python-3.x python-asyncio 2017-12-03

---

1熱

1答えて

aiohttpは暗黙的に私のメソッドを機能させます

私のaiohttpミドルウェアは、ルートに渡されたバインドされたメソッドではなく、パラメータとして機能を取得します。この行動を説明するには？それを避ける方法は？ハンドラはクラスに編成され、経路に渡された場合は class AsyncHttpServer: def __init__(self, host=None, port=None, loop=None, conf_path=None

python asynchronous python-asyncio aiohttp 2017-12-05

---

1熱

1答えて

イベントが保存された後、asyncioイベント待機機能が継続しません。

私は、WebSocketを介して応答が与えられた後に続行する必要がある機能に取り組んでいます。これを達成するために、応答が与えられた後に設定されるasyncioイベントを使用します。 三つの機能が関与している： async def send(self, message): await self.channel(message.toJSON()) if (message.meth

python python-asyncio 2017-12-06

---