PHPでAWSのSQSメッセージを処理する
受け取ったメッセージの処理ではまったのでメモ。
// メッセージを受け取る $result = $sqs->receiveMessage(array( 'QueueUrl' => $queueUrl['QueueUrl'], )); // Messagesを取得 $data = $result->get('Messages'); // null対策 if($data){ foreach($data as $item){ // Messagesの中身を取得 $res2 = json_decode($item['Body'], true); // さらにその中身を取得 $res3 = json_decode($res2['Message'], true); } }
で、ようやくキレイにデータがとれた。