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
¶
- kombu.asynchronous.http.Client(hub: Hub | None = None, **kwargs: int) CurlClient [源代码]¶
创建新的HTTP客户端。
- class kombu.asynchronous.http.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.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¶