This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
异步HTTP客户端接口- kombu.asynchronous.http.base¶
基本异步HTTP客户端实施。
- class kombu.asynchronous.http.base.Request(url, method='GET', on_ready=None, on_timeout=None, on_stream=None, on_prepare=None, on_header=None, headers=None, **kwargs)[源代码]¶
一个HTTP请求。
论点：¶
Url(Str)：要请求的URL。方法(Str)：要使用的HTTP方法(默认为
GET)。关键字参数：¶
- Headers(dict，~kombu.aschronous.http.Headers)：可选的标题
此请求
Body(Str)：该请求的可选Body。CONNECT_TIMEOUT(FLOAT)：连接超时，单位为浮点数秒
默认值为30.0。
- Timeout(Float)：请求超时前的时间(以浮点数秒为单位
默认值为30.0。
- FLOW_REDIRECTS(Bool)：指定客户端是否应该遵循重定向
默认情况下启用。
MAX_REDIRECTS(Int)：最大重定向次数(默认为6)。Use_gzip(Bool)：允许服务器使用gzip压缩。
默认情况下启用。
- Valify_cert(Bool)：如果服务器证书应为
在执行以下操作时验证
https://请求。默认情况下启用。
Auth_username(Str)：用于HTTP身份验证的用户名。AUTH_PASSWORD(Str)：HTTP认证的密码。AUTH_MODE(Str)：HTTP身份验证类型 (
basic或digest)。USER_AGENT(Str)：该请求的定制用户代理。NETWORK_INTERFACE(Str)：用于该请求的网络接口。On_Ready(Callable)：响应完成后要调用的回调收到了。必须接受单人
response争论。- On_stream(Callable)：每次正文都要调用的可选回调
已从套接字中读取内容。如果指定，则响应正文和缓冲区属性将不可用。
- On_timeout(Callable)：可选的回调，如果请求
超时。
- On_Header(Callable)：为每个标头调用的可选回调
从服务器收到的线路。签名是
(headers, line)请注意，如果您想response.headers要进行填充，则您的回调还需要调用client.on_header(headers, line)。- On_Prepare(Callable)：可选的回调，即实现
特定的(例如，cURL客户端将传递
curl实例添加到此回调)。- PROXY_HOST(Str)：可选代理主机。请注意，一个
proxy_port必须 还应提供或提供
ValueError将会被唤醒。- Proxy_Username(Str)：登录时使用的可选用户名
委托书。
- PROXY_PASSWORD(Str)：身份验证时使用的可选密码
与代理服务器连接。
Ca_certs(Str)：要使用的自定义CA证书文件。CLIENT_KEY(Str)：客户端SSL密钥的可选文件名。CLIENT_CERT(Str)：客户端SSL证书的可选文件名。
- auth_mode = None¶
- auth_password = None¶
- auth_username = None¶
- body = None¶
- ca_certs = None¶
- client_cert = None¶
- client_key = None¶
- connect_timeout = 30.0¶
- follow_redirects = True¶
- headers¶
- max_redirects = 6¶
- method¶
- network_interface = None¶
- on_header¶
- on_prepare¶
- on_ready¶
- on_stream¶
- on_timeout¶
- proxy_host = None¶
- proxy_password = None¶
- proxy_port = None¶
- proxy_username = None¶
- request_timeout = 30.0¶
- url¶
- use_gzip = True¶
- user_agent = None¶
- validate_cert = True¶
- class kombu.asynchronous.http.base.Response(request, code, headers=None, buffer=None, effective_url=None, error=None, status=None)[源代码]¶
HTTP响应。
- 参数:
(~kombu.asynchronous.http.Request) (request) --
(int) (code) --
(~kombu.asynchronous.http.Headers) (headers) --
(bytes) (buffer) --
(str) (status) --
(str) --
- request(~kombu.asynchronous.http.Request)¶
得到这样的回应。
- 类型:
对象用于执行以下操作
- code(int)¶
- 类型:
HTTP响应代码(例如200、404或500)。
- headers(~kombu.asynchronous.http.Headers)¶
以此作为回应。
- 类型:
HTTP标头
- buffer(bytes)¶
- 类型:
套接字读取缓冲区。
- effective_url(str)¶
遵循重定向。
- 类型:
之后此请求的目标url。
- error(Exception)¶
一个HTTP错误代码。
- 类型:
错误实例(如果请求导致
- buffer¶
- code¶
- property content¶
- effective_url¶
- error¶
- headers¶
- request¶
- status¶
- property status_code¶
