python-asyncio

    10

    1答えて

    asyncioを使用して非同期のクライアント/サーバーをセットアップしようとしています。 何らかの理由で、クライアントを実行しているときに私はAssertionError: yield from wasn't used with futureを取得しています。 このエラーを検索しても、それほど大きくはなりませんでした。 このエラーは何を意味し、何が原因ですか? #!/usr/bin/env pyt

    8

    2答えて

    PyPyはaioとPython 3.5をサポートしていますか? PyPyのパフォーマンスと、非同期コードasyncioが必要です。また、コード内にasync/awaitを使用する必要があります。それは可能ですか? もしそうなら、ニュアンスは何ですか?

    0

    1答えて

    私はdata_received関数でデータベースに非同期要求を行いますが、どうしたらよいか分かりません。 asyncio.sleep(2)で単純なHTTPServerを書きましたが、動作しません。 import time import asyncio class HTTPServer: def connection_made(self, transport): self

    17

    2答えて

    「と非同期」aiohttpのStartedドキュメントが次のクライアント例与える行き方: import asyncio import aiohttp async def fetch_page(session, url): with aiohttp.Timeout(10): async with session.get(url) as response: a

    1

    1答えて

    リクエストとasyncioとのリンクを取得したいのですが、サンプルプログラムがありますが、印刷機能が呼び出されるのは、私は待っています。 私は実際の関数と呼ばれる場所で印刷が呼び出されないのはなぜですか? awaitキーワードが使用されているとわかっていることは、関数が将来が見えるようになるまで中断します。私の場合、print関数は、awaitキーワードの前にprintステートメントの前に呼び出さ

    2

    1答えて

    私は、動的待ちでクローラ用のカスタムリクエストマネージャを作成したいと思います。 私のクローラは、同じIPアドレスからの並列要求を禁止するサイトへのリクエストを行う必要があります。このようなブロッキングが発生した場合、HTTPエラーコード403,503,429などで返されます。 エラーが発生した場合は、しばらくお待ちください。しかしパーサーの簡潔さのために、彼らは単に正しいページを取得して受け取る

    2

    1答えて

    以下の目標を達成する最も効率的な方法は何ですか:メインプロセスはイベントを収集してサブプロセスに配布します(イベントループrun_forever)。これらのサブプロセスは生きていて、外部からの信号を収集したり、シグナルを消費したり、CPUバウンド操作を実行したりします。これまでのところ、私はこのようなものを思いついた: import os import time import signal

    6

    1答えて

    私はscraper.pyとdb_control.pyの2つのスクリプトを持っています。データの十分が得られるまで from scraper import scrap ... while new < 15: data = scrap(category, field, pages, search, use_proxy, proxy_file) ... ... 理論的には、

    1

    1答えて

    aiocoapライブラリを使用して、埋め込みデバイスにCoAPリクエストを発行しています。コミュニケーションと基本的な機能はうまくいくようですが、ドキュメンテーションは観察を有効にする方法を述べていません。監視機能はがソースコードに存在するように見えますが、サーバー側とクライアント側の両方に存在します。クライアント側が必要です。 これは私がこれまで持っているものです:サーバー上で観察する状態を作成

    5

    1答えて

    tqdm進捗バーを統合して、aiohttpで生成されたPOST要求をPython 3.5で監視しようとしています。私は進行中のバーを持っていますが、as_completed()を使って結果を集めるように見えません。ポインタは感謝して受け取りました。私が見つけた 例としては、Pythonと互換性がありません。次のパターンを、使用することをお勧め3.5 async def定義: for f in tq