Amazon SQS在php中发送消息属性

Question

我需要实现向带有属性的SQS发送消息。消息的正文上传良好，但我有问题的属性。消息属性需要具有属性名称、数据类型和值的关联数组。我有这样的错误：

public function uploadMessage(DataTransferObjectInterface $dataTransferObject)
{

    $command = $this->client->getCommand(
        'SendMessage',
        [
            'QueueUrl' => $this->queueUrl->value(),
            'MessageBody' => $dataTransferObject->getBody()->value(),
            'MessageAttributes' => $dataTransferObject->getAttributes(),

        ]
    );

    $this->client->execute($command);

}

   $attributes = [
   'TestName' =>
            [
            'Name'=>'test',
            'DataType' => 'string',
            'Value' => 'string',

        ]
    ];
    $age = array("Peter" => "35", "Ben" => "9", "Joe" => "43");
    $json = json_encode($age);
    $body = Json::get($json);

    $dto = new DataTransferObject($attributes, $body);

    $uploader = new SQSManager($sqsClient, $queueUrl);
    $uploader->uploadMessage($dto);

$Attributes数组应该是什么样子？

Answer 1

版本3.2.1及更高版本中内置了此错误的修复程序。

此外，您的消息属性数组与文档中显示的格式不匹配。您的属性应该如下所示：

$attributes = [
    '<attribute name>' => [
        'DataType' => 'String',
        'StringValue' => '<attribute value>',
    ],
];