私はPreparedRequestを知っています.ここですでに見たように、session.send
呼び出しでタイムアウトを指定します。session
requests.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
オブジェクトを引数として取得しています。session
session.send の並列実行が発生する前に、オブジェクトと共に送信されるすべてのリクエストのタイムアウトを設定する方法はありますか?
ありがとうございました。