python-asyncio

3熱

1答えて

コールバックと同期待ちの束なしで、別のスレッドからasyncioコルーチンをスケジューリングする

this質問をする必要があります。メッセージを送信するコルーチンsendがあります。私は（スレッド2で実行されている）loop2から（スレッド1で実行されている）loop1でそれをスケジュールする： async def send_threadsafe(self, message, current_loop=loop2, dest_loop=loop1): future = asynci

2熱

1答えて

なぜ親コルーチンがキャンセルされないのですか？

私はPython asyncioで遊んでいます。私のプログラムはコルーチンが3つしかありません。そのうちの2つは私が直接スケジュールし、3つ目はフォーマーの1人から予定されています。実際ががキャンセルされたcoro2がキャンセルされなかった理由 coro1 coro2 coro3 ^CExiting... Cancelling all tasks Cancellation is done!

1熱

1答えて

asyncioのタスクトップアップ

私のプロジェクトでは、私が実行するタスクの一覧があります。 loop.run_until_complete(tasks) しかし、無限の数のタスクがあるので、現時点では、それらをバッチで実行します。私は、タスクの数、Iランチ非同期にこれらのタスクを実行するためにループを使用して結果を返す通常の関数を得る def get_results(tasks): return [result f

3熱

1答えて

asyncioとwebsocketコールバックを非同期にする

asyncioとwebsocketsとPython 3.5.2を使用して、基本WebSocketクライアントを実装しようとしています。基本的には、connect_to_dealerをブロッキングコールにしたいが、別のスレッドでwebsocketメッセージを待つ。いくつかのドキュメントを読んだあと（私はPythonにはほとんど経験がありません）、私はasyncio.ensure_future()

1熱

1答えて

asynioとaiohttpを使用して、リモートマシンとローカルのポストを多数作成できない

asyncioとaiohttpを使用してイベントをポストするプログラムを作成しました。このプログラムは、ローカルで実行すると動作します。私は10kイベントを問題なく投稿できます。しかし、私は、リモートマシンに全体のコードベースをSCPed、そのマシンの中に、私はこのエラーを取得せずに15の以上のイベントをポストすることはできません。 RuntimeError: Event loop is clos

1熱

1答えて

aiomysql

にエラー「イベントループが閉じられている」私はここに（順番にaiomysqlを使用しています）ピーウィー・非同期を使用してMySQLを照会に問題を持っている私のコードは、（私はそれがピーウィー・非同期からの例とほとんど同じだと思うですdoc）：これを実行すると、クエリと印刷が行われます（私の場合は1人のユーザー）。しかし、それは例外をスローする： (env)[email protected]:

1熱

2答えて

例として、次のコードを取るのPython 3

に機能を殺すためにSIGINTを使用した： import signal import time def stop(signal, frame): print("You pressed ctrl-c") # stop counter() def counter(): for i in range(20): print(i+1) time

2熱

1答えて

PythonのAsyncioがクロール

に遅くなり、私は次の行でそれを実行すると、私は非同期的にいくつかのURLをダウンロードするスクリプトを持って、その後、連続difflib import asyncio import difflib import aiohttp urls = ['http://www.nytimes.com/', 'http://www.time.com/', 'http://www

1熱

1答えて

asyncioを並列タスクに使用

私はasyncioを使ってnodeJSと同様のタスクを処理する方法を知りました。スレッドを開かずに同時にタスクを実行したい。例： import asyncio @asyncio.coroutine def my_coroutine(task_name, seconds_to_sleep=3): print('{0} sleeping for: {1} seconds'.forma

1熱

2答えて

Asyncioはタスクを非同期に実行しません

私はasyncioのPythonモジュールで遊んでいますが、私の単純なコードで何が問題なのか分かりません。非同期にタスクを実行することはありません。 #!/usr/bin/env python3 import asyncio import string async def print_num(): for x in range(0, 10): print('N