python-asyncio

    1

    1答えて

    まあ、私はPython3を使ってDiscordボットに取り組んでいますが、ある程度は動作しますが、数分ごとにクラッシュし続けます。それは私に "タスクは停止されましたが、保留中です"というエラーが表示されます。今、問題を探して、自分のレスポンス= request.get(url)を取り除き、それを "async with aiohttp.get(url)in response"に置き換えなければな

    0

    1答えて

    zmqソケットを持つtcpサーバーを作成したいと思います。次のコードは、Pythonのasyncioのioloopを使ってzmqソケットを使ってtcpサーバーを作成します。 次のコードでは、着信接続を待機するzmqソケットを作成しています。コルーチンrecv_and_processは、接続をリッスンし、着信接続に応答するwhileループを持つソケットを作成します。 私の質問は、whileループを排

    1

    2答えて

    なぜasyncioキューは、そこに項目を置いても空であるにもかかわらず、奇妙な挙動をしているのですか? In [1]: from multiprocessing import Queue In [2]: q = Queue() In [3]: q.empty() Out[3]: True In [4]: q.put(100) In [5]: q.empty() Out[5]:

    3

    2答えて

    は私がaiohttpオーバーヘッダー値としてバイトを送信しようとしています: payload = { #ommited for brevity } encoded_payload = str.encode(json.dumps(payload)) b64 = base64.b64encode(encoded_payload) # sign the requests signatur

    2

    1答えて

    私はSanicと協力していますが、ちょっと残念です。私は、それぞれ独自の応答時間を持つ3種類のAPIを呼び出しています。 各タスクが復帰するのに許容される時間を提供するタイムアウト関数を作成します。しかし、時間のタスクが許容時間内に完了していない場合、私は完全なデータセットを必要とせず、速度がより重視されるため、部分的なデータを返したいと思います。 しかし、私が完了(すなわち。APIデータを要求し

    1

    1答えて

    同期方式でデータをアップロードする高速非同期RESTインターフェイス呼び出しを実装しています。現時点では、非同期の方法でPythonページを呼び出し、遅延を測定する非同期フレームワークを構築しようとしています。私は await perform_call(session) を使用していますが、それは明らかにasynchonous電話を壊してそれが正常に限り動作します import aiohttp

    1

    1答えて

    次のコードスニペットには、サーバーとクライアントの2つのコルーチンがあります。クライアントコルーチンには、10秒後にwhileループを切断するロジックがあり、15秒後にサーバーが停止する必要があります。 スクリプトを実行すると、これは停止しません。理想的には、15秒後に停止する必要がありますが、これは起こっていません。あなたは、コードを実行した場合 import asyncio import t

    2

    1答えて

    asyncioを使って簡単なエコーサーバを実装しようとしています。 import asyncio async def process(reader, writer): while True: data = await reader.readline() writer.write(data) loop = asyncio.get_event_loop()

    1

    1答えて

    非同期ジェネレータを組み合わせて実際に実行する際に問題があります。これは、私がそれらを実行するために見つけた唯一の方法は、ジェネレータではなく、反復可能なものを返すイベントループによるものです。 GoogleがGoogleを検索するGoogleの検索機能(私は意図的にAPIを使用していない)を持っているとしましょう。検索文字列を取り込み、検索結果のジェネレータを返します。このジェネレータは、ページ