tokisabaのブログ

エンジニア系シェアハウスEngineMakerの管理人ブログ

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);
    }
}

で、ようやくキレイにデータがとれた。