alexapy.aiohttp.client_reqrep

Classes

• ClientRequest: Undocumented.

• ClientResponse: Undocumented.

• RequestInfo: Undocumented.

• Fingerprint: Undocumented.

class alexapy.aiohttp.client_reqrep.ClientRequest(method: str, url: yarl.URL, *, params: Optional[Mapping[str, str]] = None, headers: Optional[Union[Mapping[Union[str, multidict._multidict.istr], str], multidict._multidict.CIMultiDict, multidict._multidict.CIMultiDictProxy]] = None, skip_auto_headers: Iterable[str] = frozenset({}), data: Any = None, cookies: Optional[Union[Mapping[str, Union[str, BaseCookie[str], Morsel[Any]]], Iterable[Tuple[str, Union[str, BaseCookie[str], Morsel[Any]]]], BaseCookie[str]]] = None, auth: Optional[alexapy.aiohttp.helpers.BasicAuth] = None, version: alexapy.aiohttp.http_writer.HttpVersion = HttpVersion(major=1, minor=1), compress: Optional[str] = None, chunked: Optional[bool] = None, expect100: bool = False, loop: Optional[asyncio.events.AbstractEventLoop] = None, response_class: Optional[Type[ClientResponse]] = None, proxy: Optional[yarl.URL] = None, proxy_auth: Optional[alexapy.aiohttp.helpers.BasicAuth] = None, timer: Optional[alexapy.aiohttp.helpers.BaseTimerContext] = None, session: Optional[ClientSession] = None, ssl: Optional[Union[ssl.SSLContext, bool, alexapy.aiohttp.client_reqrep.Fingerprint]] = None, proxy_headers: Optional[Union[Mapping[Union[str, multidict._multidict.istr], str], multidict._multidict.CIMultiDict, multidict._multidict.CIMultiDictProxy]] = None, traces: Optional[List[Trace]] = None)

Inheritance

update_auth(auth: Optional[alexapy.aiohttp.helpers.BasicAuth]) → None

Set basic auth.

update_content_encoding(data: Any) → None

Set request content encoding.

update_cookies(cookies: Optional[Union[Mapping[str, Union[str, BaseCookie[str], Morsel[Any]]], Iterable[Tuple[str, Union[str, BaseCookie[str], Morsel[Any]]]], BaseCookie[str]]]) → None

Update request cookies header.

update_headers(headers: Optional[Union[Mapping[Union[str, multidict._multidict.istr], str], multidict._multidict.CIMultiDict, multidict._multidict.CIMultiDictProxy]]) → None

Update request headers.

update_host(url: yarl.URL) → None

Update destination host, port and connection type (ssl).

update_transfer_encoding() → None

Analyze transfer-encoding header.

update_version(version: Union[alexapy.aiohttp.http_writer.HttpVersion, str]) → None

Convert request version to two elements tuple.

parser HTTP version ‘1.1’ => (1, 1)

async write_bytes(writer: alexapy.aiohttp.abc.AbstractStreamWriter, conn: Connection) → None

Support coroutines that yields bytes objects.

class alexapy.aiohttp.client_reqrep.ClientResponse(method: str, url: yarl.URL, *, writer: asyncio.Task[None], continue100: Optional[asyncio.Future[bool]], timer: alexapy.aiohttp.helpers.BaseTimerContext, request_info: alexapy.aiohttp.client_reqrep.RequestInfo, traces: List[Trace], loop: asyncio.events.AbstractEventLoop, session: ClientSession)

Inheritance

history

A sequence of of responses, if redirects occurred.

async json(*, encoding: typing.Optional[str] = None, loads: typing.Callable[[str], typing.Any] = <function loads>, content_type: typing.Optional[str] = 'application/json') → Any

Read and decodes JSON response.

property ok: bool

Returns True if status is less than 400, False if not.

This is not a check for 200 OK but a check that the response status is under 400.

async read() → bytes

Read response payload.

async start(connection: Connection) → ClientResponse

Start response processing.

async text(encoding: Optional[str] = None, errors: str = 'strict') → str

Read response payload and decode.

class alexapy.aiohttp.client_reqrep.RequestInfo(url: yarl.URL, method: str, headers: multidict._multidict.CIMultiDictProxy, real_url: yarl.URL = NOTHING)

Inheritance

class alexapy.aiohttp.client_reqrep.Fingerprint(fingerprint: bytes)

Inheritance