AWS SQS使用收据句柄删除消息 - AWS SQS Delete Messages Using Receipt Handle

AWS SQS Delete Messages Using Receipt Handle

本文关键字：句柄删除消息 SQS AWS | 更新日期: 2023-09-27

我正在尝试设置SQS，收到消息后，我需要将其从队列中删除。

创建客户端-

$client = Aws'Sqs'SqsClient::factory(array(
                    'key'    => '******',
                    'secret' => '******',
                    'region' => 'ap-southeast-1'
            ));

发送消息

public static function SendMessage()
    {
        if(!isset(self::$queueUrl))
            self::getQueueUrl();
        $command = "This is a command";
        $commandstring = json_encode($command);
        self::$client->sendMessage(array(
                'QueueUrl'    => self::$queueUrl,
                'MessageBody' => $commandstring,
        ));
    }

接收消息

public static function RecieveMessage()
    {
        if(!isset(self::$queueUrl))
            self::getQueueUrl();
        $result = self::$client->receiveMessage(array(
                'QueueUrl' => self::$queueUrl,
        ));
//      echo "Message Recieved >>  ";
        print_r($result);
        foreach ($result->getPath('Messages/*/Body') as $messageBody) {
            // Do something with the message
            echo $messageBody;
            //print_r(json_decode($messageBody));
        }
        foreach ($result->getPath('Messages/*/ReceiptHandle') as $ReceiptHandle) {
            self::$client->deleteMessage(self::$queueUrl, $ReceiptHandle);
        }
    }

当我尝试使用receive消息代码中的receive Handle删除消息时，我从Guzzle -得到错误可捕获的致命错误:参数2传递给Guzzle'Service'Client::getCommand()必须是一个数组，字符串给定，

现在在搜索了很多之后，我能够找到类似的问题，这些问题表明他们使用了错误的SDK版本。但我仍然无法缩小范围。我使用的是最新sdk 2.6.15的zip版本

你为什么不试试呢?

self::$client->deleteMessage(array(
    'QueueUrl' => self::$queueUrl,
    'ReceiptHandle' => $ReceiptHandle,
));

SqsClient::deleteMessage()(和其他操作)的API文档中的基本格式化示例应该有所帮助。所有执行操作的方法都只接受一个参数，即操作参数的关联数组。您应该通读SDK的入门指南(如果您还没有)，其中讨论了如何执行一般操作。