来自amazonsqsjavaextendedclientlib的AWS SQS扩展客户端功能
sqs-extended-client的Python项目详细描述
sqs扩展客户端
在Python
中实现amazon-sqs-java-extended-client-lib的功能安装
pip install sqs-extended-client
概述
sqs扩展客户端允许通过S3通过sqs发送大消息。这是与Amazon库相同的机制 amazon-sqs-java-extended-client-lib提供。这个图书馆是 可与该库互操作。在
为此，该库在使用botoinator库导入时自动扩展普通的boto3sqs客户机和队列资源类。如果需要的话，这允许进一步扩展或装饰。在
使用
注
s3存储桶在使用之前必须已经存在，并且可以通过任何可用的凭据进行访问
支持大型有效负载（>256Kb）
^{pr2}$参数：
- large_payload_支持——将存储大消息的S3 bucket名称。在
支持大有效载荷（>64K）
importboto3importsqs_extended_client# Low level clientsqs=boto3.client('sqs')sqs.large_payload_support='my-bucket-name'sqs.message_size_threshold=65536# boto resourceresource=boto3.resource('sqs')queue=resource.Queue('queue-url')# Orqueue=resource.create_queue(QueueName='queue-name')queue.large_payload_support='my-bucket-name'queue.message_size_threshold=65536
参数：
- message_size_threshold—将消息存储在大型消息存储桶中的阈值。不能小于0或大于262144
支持所有消息的大有效负载
importboto3importsqs_extended_client# Low level clientsqs=boto3.client('sqs')sqs.large_payload_support='my-bucket-name'sqs.always_through_s3=True# boto resourceresource=boto3.resource('sqs')queue=resource.Queue('queue-url')# Orqueue=resource.create_queue(QueueName='queue-name')queue.large_payload_support='my-bucket-name'queue.always_through_s3=True
参数：
- 总是从\u到\u s3--如果为True，则所有消息都将序列化到s3。在
- 项目
标签：
欢迎加入QQ群-->： 979659372
