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 Connection.

class kombu.asynchronous.aws.connection.AsyncConnection(sqs_connection, http_client=None, **kwargs)

Async AWS Connection.

get_http_connection()

class kombu.asynchronous.aws.connection.AsyncHTTPSConnection(strict=None, timeout=20.0, http_client=None)

Async HTTP Connection.

class Request(url, method='GET', on_ready=None, on_timeout=None, on_stream=None, on_prepare=None, on_header=None, headers=None, **kwargs)

A HTTP Request.

Parameters

• url (str) – The URL to request.

• method (str) – The HTTP method to use (defaults to GET).

Keyword Arguments

• headers (Dict, Headers) – Optional headers for this request

• body (str) – Optional body for this request.

• connect_timeout (float) – Connection timeout in float seconds Default is 30.0.

• timeout (float) – Time in float seconds before the request times out Default is 30.0.

• follow_redirects (bool) – Specify if the client should follow redirects Enabled by default.

• max_redirects (int) – Maximum number of redirects (default 6).

• use_gzip (bool) – Allow the server to use gzip compression. Enabled by default.

• validate_cert (bool) – Set to true if the server certificate should be verified when performing https:// requests. Enabled by default.

• auth_username (str) – Username for HTTP authentication.

• auth_password (str) – Password for HTTP authentication.

• auth_mode (str) – Type of HTTP authentication (basic or digest).

• user_agent (str) – Custom user agent for this request.

• network_interface (str) – Network interface to use for this request.

• on_ready (Callable) – Callback to be called when the response has been received. Must accept single response argument.

• on_stream (Callable) – Optional callback to be called every time body content has been read from the socket. If specified then the response body and buffer attributes will not be available.

• on_timeout (callable) – Optional callback to be called if the request times out.

• on_header (Callable) – Optional callback to be called for every header line received from the server. The signature is (headers, line) and note that if you want response.headers to be populated then your callback needs to also call client.on_header(headers, line).

• on_prepare (Callable) – Optional callback that is implementation specific (e.g. curl client will pass the curl instance to this callback).

• proxy_host (str) – Optional proxy host. Note that a proxy_port must also be provided or a ValueError will be raised.

• proxy_username (str) – Optional username to use when logging in to the proxy.

• proxy_password (str) – Optional password to use when authenticating with the proxy server.

• ca_certs (str) – Custom CA certificates file to use.

• client_key (str) – Optional filename for client SSL key.

• client_cert (str) – Optional filename for client SSL certificate.

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

alias of kombu.asynchronous.aws.connection.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)