python-asyncio

1熱

1答えて

私はasyncio UDP server exampleで遊んでおり、datagram_receivedの方法からsleepを取得したいと考えています。 import asyncio class EchoServerProtocol: def connection_made(self, transport): self.transport = transport

4熱

2答えて

Python 3.5 asyncioは、異なるスレッドの同期コードからイベントループでcoroutineを実行します。

私は誰かが私を助けてくれることを望んでいます。私はコルーチンオブジェクトを返す属性を持つオブジェクトを持っています。これはきれいに動作しますが、イベントループが現在実行されている間に、独立したスレッドで同期コードからコルーチンオブジェクトの結果を取得する必要がある状況があります。私が思いついたコードは次のとおりです。 def get_sync(self, key: str, default: t

2熱

1答えて

Pythonでマルチスレッドasyncio

現在、私はasyncioでPython 3.5で私の最初のステップをやっています。明らかに私はコルーチンを完全に理解していません... ここでは私がやっていることの単純化バージョンです。私のクラスには、新しいスレッドを作成するopen（）メソッドがあります。そのスレッド内で、新しいイベントループといくつかのホストへのソケット接続を作成します。それから私はループを永遠に走らせます。接続を停止 de

3熱

1答えて

Sphinxオートドックを使用したPythonコルーチンの文書化

最初のasyncioベースのプロジェクトをSphinxで文書化し始めました。私はいくつかの方法の前に "coroutine"という接頭辞が付いているプロジェクトがあることに気付きました。私はプロジェクトのドキュメントで同じことをしたいと思いますが、どうやって解決するのか分かりません。例えば、aiohttp's HTTP client referenceはこのことを示していますクラスaiohtt

1熱

2答えて

コルーチンを含むpythonスニペットを実行中にエラーが発生しました

pythonの新機能https://docs.python.org/3/library/asyncio-task.htmlから次のサンプル・プログラムを実行しようとしたが、ここでエラー $ python coro.py File "coro.py", line 3 async def compute(x, y): ^ SyntaxError: invalid sy

3熱

1答えて

このスタイルは、竜巻と一緒にスレッドプールを使用するのですか？

だから私は私のクラスで executor = ThreadPoolExecutor(100) をキュータと呼ばれるクラス変数を作成し、代わりに関数やメソッドを持つとデコレータを使用しての、私は単に私のブロッキングタスクを処理するために、次の行を使用します（IOとハッシュ作成のようなと... ...）私の非同期メソッド result = await to_tornado_future(self.

1熱

1答えて

asyncioの協調歩留り

私は、（竜巻）ウェブサーバで長いCPU集約型タスクを実行しています。私はスレッドにこのタスクをオフロードしたくない（今のところ）。この長時間実行されているタスクの制御をイベントループに正しく "もたらす"ため、Webリクエストはまだ配信されています（注：ジェネレータセンスではなく、協調スケジューリングの意味で "yield"を使用しています、またはpythonキーワードyield）。私の提案はa

2熱

1答えて

接続2つのプロセスは（asyncio.subprocess.create_subprocess_execで開始）古い学校<code>subprocess.Popen()</code> APIを持つ2つのプロセスを起動すると

、私は簡単でパイプラインを作成し、別のプロセスのに標準に一つのプロセスのうち標準を接続することができますUNIXシェルは|との接続のコマンドを実行しますと同じ方法： asyncio.subprocess.create_subprocess_exec()（または類似）から非同期APIを使用しているとき、私は同じことを達成することができますどのように from subprocess import Po

0熱

1答えて

非同期ライブラリから非同期呼び出しを行う？

toy scriptはasyncio-認識していない、と明らかに動作していない実装に依存しているクラスを使用してアプリケーションを示しています。どうMyFetcherのフェッチ方法はまだFetcherAppの_internal_validator方法との契約を維持しながら、asyncio対応クライアントを使用して、実施されるのでしょうか？非常に明確にするために、FetcherAppとAbstra

2熱

2答えて

Python asyncio with Slackボット

asyncioを使用して単純なSlackボットを作成しようとしています。これは主に、asyncioの部分にhere、Slackの部分にhereの例を使用しています。これらの例はどちらも単独で動作しますが、それらをまとめるとループがループしないように見えます。 infoが1の長さのリストである場合、ボットが入っているチャットルームにメッセージが入力されたときにコルーチンがトリガーされるはずですが、