如何使用python sdk中的sample代码？

在阿里云中，使用Python SDK操作消息服务（MNS）涉及几个关键步骤，您已经概述了创建队列、发送消息、接收并删除消息以及删除队列的基本流程。下面我将补充一些核心代码示例和解释，帮助您更好地理解如何使用Python SDK完成这些操作。

1. 导入必要的库

首先，确保您已安装阿里云的Python SDK，可以通过pip安装：

pip install aliyun-python-sdk-mns

然后，在您的Python脚本中导入必要的模块：

from aliyunsdkcore.profile import region_provider
from aliyunsdkmns.request.v20220119 import CreateQueueRequest, SendMessageRequest, ReceiveMessageRequest, DeleteMessageRequest, DeleteQueueRequest
from aliyunsdkmns import Client
import json

2. 初始化客户端

根据sample.cfg文件中的配置初始化MNS客户端：

def get_client():
    # 从配置文件读取AccessKeyId、AccessKeySecret、Endpoint等信息
    with open('sample.cfg', 'r') as f:
        config = json.load(f)
    
    region_provider.add_endpoint(config['Endpoint'], 'MNS', 'cn-hangzhou')  # 根据实际Endpoint调整区域
    
    client = Client(
        config['AccessKeyId'],
        config['AccessKeySecret'],
        # 如果使用STS Token，需要添加此行
        # security_token=config['SecurityToken'],
        endpoint=config['Endpoint']
    )
    return client

3. 创建队列

使用CreateQueueRequest创建队列：

def create_queue(queue_name):
    client = get_client()
    request = CreateQueueRequest.CreateQueueRequest()
    request.set_QueueName(queue_name)
    response = client.do_action_with_exception(request)
    print(response)

4. 发送消息

通过SendMessageRequest发送消息到队列：

def send_message(queue_name, message_body):
    client = get_client()
    request = SendMessageRequest.SendMessageRequest()
    request.set_QueueName(queue_name)
    request.set_MessageBody(message_body)
    response = client.do_action_with_exception(request)
    print(response)

5. 接收并删除消息

利用ReceiveMessageRequest和DeleteMessageRequest实现长轮询接收并删除消息：

def receive_and_delete_message(queue_name):
    client = get_client()
    receive_request = ReceiveMessageRequest.ReceiveMessageRequest()
    receive_request.set_QueueName(queue_name)
    receive_request.set_WaitSeconds(3)  # 等待时间设置为3秒
    receive_response = client.do_action_with_exception(receive_request)
    messages = receive_response.get('Messages').get('Message')
    for message in messages:
        receipt_handle = message.get('ReceiptHandle')
        delete_request = DeleteMessageRequest.DeleteMessageRequest()
        delete_request.set_QueueName(queue_name)
        delete_request.set_ReceiptHandle(receipt_handle)
        client.do_action_with_exception(delete_request)
        print(f"Deleted message with ReceiptHandle: {receipt_handle}")

6. 删除队列

最后，当不再需要队列时，可以使用DeleteQueueRequest删除它：

def delete_queue(queue_name):
    client = get_client()
    request = DeleteQueueRequest.DeleteQueueRequest()
    request.set_QueueName(queue_name)
    response = client.do_action_with_exception(request)
    print(response)

请根据您的具体需求调用上述函数，并适当处理异常情况以增强程序的健壮性。