1

私はPreparedRequestを知っています.ここですでに見たように、session.send呼び出しでタイムアウトを指定します。sessionrequests.Session

しかし、送信する前にタイムアウトを設定する必要があります。やや本質的に、PreparedRequest オブジェクトに。session.sendメソッドをマップ関数として使用しているため、PreparedRequest インスタンスにマップします。

def async_req2resp(reqs, session):
    responses = []
    try:
        with futures.ThreadPoolExecutor(max_workers=workers) as executor:
            for response in executor.map(session.send, requests):
                responses.append(response)
    except Exception as e:
        print('async_requests2responses exception: ' + str(e))
    return responses

ここで、何らかの方法でタイムアウトを指定する必要があります。どうすればいいですか?上記のコードは、メソッド内にラップされています。sessionオブジェクトを引数として取得しています。sessionsession.send の並列実行が発生する前に、オブジェクトと共に送信されるすべてのリクエストのタイムアウトを設定する方法はありますか?

ありがとうございました。

4

1 に答える 1