python-asyncio

0熱

1答えて

私は中央スケジューラモードでluigiを使用しようとしています。私は、コマンド $ luigid を使用して、中央スケジューラを実行しようとするたびにそれは Traceback (most recent call last): File "/usr/local/bin/luigid", line 9, in <module> load_entry_point('luigi==2

-1熱

1答えて

後にwebsocket.recv（）でハングアップしますか？

あいまいな質問に対する謝罪 - 私は実際にこれが働かなくなった私が何を変えたのか分かりません。私はWebSocketを使用してPythonでテキストアドベンチャーエンジン（オープンソースプロジェクト）に取り組んでいます。これはasyncioとwebsocketsモジュールでうまくいきました。私は物事を少し動かし、今入力を受け取ったときにハングアップします。私は嘘をついた - それは決して働か

0熱

1答えて

raise "mongoimport"タスクをスケジュールしようとするとRuntimeError（ 'イベントループが閉じています'）

ここでは異常なエラーです。 "asyncio"を使用して "mongoimport"タスクをスケジュールしようとすると遭遇しました。いったんmongodサービスを開始し、ターミナルで生成したコマンドを貼り付けると、うまくいきました。私はpython3.4のasyncioを使用しようとすると、しかし、問題が来る：ここ File "/Users/wangyi/Documents/workspace/M

1熱

1答えて

asyncioイベントループを使用してtornado.testing.AsyncTestCaseを実行します。

私はユニットテストをしたいasyncioベースのクラスを持っています。 tornado.testing.AsyncTestCaseを使用すると、これは非常にうまく簡単に機能します。しかし、私のクラスの特定のメソッドの1つはasyncio.ensure_futureを使って別のメソッドの実行をスケジュールします。これはAsyncTestCaseで決して終了しません。デフォルトのテストランナーは、as

0熱

1答えて

Asyncio：非常に単純な書き込みと切断のUDPクライアントでの問題

新しいasyncioモジュールをPython 3.5.1から試してみました。私はこれがself.transport.sendto(self.message.encode())とself.transport.close()のシーケンスによって引き起こされると考え Traceback (most recent call last): File "C:\Users\oxygen\Documen

1熱

2答えて

一度にN個のジョブを処理するAsyncioワーカー？

私はasyncioジョブキューからジョブを消費し、並行してNジョブを処理するワーカークラスを作ろうとしています。ジョブによっては、追加のジョブをキューに入れることがあります。ジョブキューが空で、作業者が現在のすべてのジョブを終了すると、ジョブキューは終了するはずです。私はまだ概念的にasyncioと苦労しています。ここに私の試みの一つ、N=3です： import asyncio, logging

2熱

2答えて

loop_foreverで未来を使うPython

ちょうど本当にクールに見えるasynchで実験を始めました。私は永遠に走る非同期のコルーチンで先物を使用しようとしているが、私はこのエラーを取得： Task exception was never retrieved future: <Task finished coro=<slow_operation() done, defined at ./asynchio-test3.py:5> exce

-1熱

1答えて

asyncioを使ってこのpythonコードをクリアして改善するには？

私は、複数のサイトのステータスを監視するPythonスクリプトをコーディングしています。他のウェブサイトのチェックでブロックされることなく、正確な間隔でウェブサイトのステータスをチェックするはずだから、私はasyncioを使っています。しかし、私はSIGINTシグナルを捕まえたときに正しく停止しないか、間違ってすべてやっているようです。 /usr/lib/python3.5/asyncio/u

3熱

2答えて

asyncio +マルチプロセッシング+ UNIX

は、私は次のロジックを持つペットのプロジェクトを持っています。しかし、私がしなければならない代わりにstart()コルーチンようにすることです。それを実行するには async def start(): multiprocessing.Process(target=sub_loop).start() を、私はそのような何かしなければならない。ここで asyncio.get_event_

3熱

1答えて

asyncioでプロトコルまたはストリームを使用する必要がありますか？

私はasyncioに非常に新しく、より良いプラクティス、プロトコル、またはストリームという点で、どのAPIが他のAPIより優れているのだろうかと疑問に思っていましたか？私には、すでにconnection_madeとdata_receivedメソッドが提供されているので、私にはprotocol(callback based API)が使いやすいようです。 streams(coroutine bas