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

SQS报文- kombu.asynchronous.aws.sqs.message

Amazon SQS消息实现。

class kombu.asynchronous.aws.sqs.message.AsyncMessage(body=None, delivery_tag=None, content_type=None, content_encoding=None, delivery_info=None, properties=None, headers=None, postencode=None, accept=None, channel=None, **kwargs)[源代码]

序列化消息。

accept
body
channel
content_encoding
content_type
delivery_info
delivery_tag
encode(value)[源代码]

使用Base64编码编码/解码值。

headers
properties
class kombu.asynchronous.aws.sqs.message.AsyncRawMessage(body=None, delivery_tag=None, content_type=None, content_encoding=None, delivery_info=None, properties=None, headers=None, postencode=None, accept=None, channel=None, **kwargs)[源代码]

原始消息。

accept
body
channel
content_encoding
content_type
delivery_info
delivery_tag
headers
properties
class kombu.asynchronous.aws.sqs.message.BaseAsyncMessage(body=None, delivery_tag=None, content_type=None, content_encoding=None, delivery_info=None, properties=None, headers=None, postencode=None, accept=None, channel=None, **kwargs)[源代码]

在异步客户端上接收的消息的基类。

accept
body
channel
content_encoding
content_type
delivery_info
delivery_tag
headers
properties