This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

Amazon AWS Connection- kombu.asynchronous.aws.connection

Amazon AWS连接。

class kombu.asynchronous.aws.connection.AsyncConnection(sqs_connection, http_client=None, **kwargs)[源代码]

异步AWS连接。

get_http_connection()[源代码]
class kombu.asynchronous.aws.connection.AsyncHTTPSConnection(strict=None, timeout=20.0, http_client=None)[源代码]

异步HTTP连接。

class 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
then(callback, errback=None)
url
use_gzip = True
user_agent = None
validate_cert = True
Response

AsyncHTTPResponse 的别名

body = None
close()[源代码]
connect()[源代码]
default_ports = {'http': 80, 'https': 443}
endheaders()[源代码]
getrequest()[源代码]
getresponse(callback=None)[源代码]
method = 'GET'
path = '/'
putheader(header, value)[源代码]
putrequest(method, path)[源代码]
request(method, path, body=None, headers=None)[源代码]
send(data)[源代码]
set_debuglevel(level)[源代码]