3.1. SQSキューからのメッセージ受信+削除 (handson-cli-cloudwatch-1st-queue)¶

手順の目的¶

SQSキュー"handson-cli-cloudwatch-1st-queue"のメッセージを受信・削除します。

設定値の指定¶

手順に必要な設定値を変数に格納をします。

0. リージョン¶

リージョンを指定します。

環境変数の設定:
export AWS_DEFAULT_REGION='ap-northeast-1'

1. SQSキュー名¶

SQSキュー名を指定します。

変数の設定:

SQS_QUEUE_NAME="handson-cli-cloudwatch-1st-queue"

2. 一時ディレクトリ¶

受信中メッセージ用一時ディレクトリを指定します。

変数の設定:

DIR_TMP="${HOME}/environment/tmp-handson-cli-cloudwatch-1st"

ディレクトリが存在することを確認し、存在しない場合は作成します。

コマンド:

ls -d ${DIR_TMP} > /dev/null 2>&1 \
  || mkdir -p ${DIR_TMP}

3. SQSメッセージファイル名¶

SQSメッセージファイル名を指定します。

変数の設定:

FILE_SQS_MESSAGE="${DIR_TMP}/hello_world.json" \
  && echo ${FILE_SQS_MESSAGE}

結果(例):

${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json

設定値の確認¶

各変数に正しい設定値が格納されていることを確認します。

変数の確認:

cat << END

  # 0. AWS_DEFAULT_REGION:"ap-northeast-1"
       AWS_DEFAULT_REGION="${AWS_DEFAULT_REGION}"

  # 1. SQS_QUEUE_NAME:"handson-cli-cloudwatch-1st-queue"
       SQS_QUEUE_NAME="${SQS_QUEUE_NAME}"
  # 2. DIR_TMP:"${HOME}/environment/tmp-handson-cli-cloudwatch-1st"
       DIR_TMP="${DIR_TMP}"
  # 3. FILE_SQS_MESSAGE:"${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json"
       FILE_SQS_MESSAGE="${FILE_SQS_MESSAGE}"

END

下段の変数が入っていない、もしくは上段と同等の値が入っていない場合は、それぞれの手順番号に戻って変数の設定を行います。

処理の実行¶

SQSキューのURLを取得します。

コマンド:

sqs_queue_url=$( \
  aws sqs get-queue-url \
    --queue-name ${SQS_QUEUE_NAME} \
    --output text \
) \
  && echo ${sqs_queue_url}

結果(例):

https://ap-northeast-1.queue.amazonaws.com/XXXXXXXXXXXX/handson-cli-cloudwatch-1st-queue

SQSキューからメッセージを受信します。

変数の確認:

cat << END

  # sqs_queue_url:"https://ap-northeast-1.queue.amazonaws.com/XXXXXXXXXXXX/handson-cli-cloudwatch-1st-queue"
    sqs_queue_url="${sqs_queue_url}"
  # FILE_SQS_MESSAGE:"${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json"
    FILE_SQS_MESSAGE="${FILE_SQS_MESSAGE}"

END

コマンド:

aws sqs receive-message \
  --queue-url "${sqs_queue_url}" \
  > ${FILE_SQS_MESSAGE} \
    && cat ${FILE_SQS_MESSAGE}

結果(例):

{
    "Messages": [
        {
            "MessageId": "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx",
            "ReceiptHandle": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx=",
            "MD5OfBody": "ed076287532e86365e841e92bfc50d8c",
            "Body": "Hello World!"
        }
    ]
}

メッセージの受信ハンドルを取得します。

コマンド:

sqs_message_receipt_handle=$( \
  echo $( \
    cat ${FILE_SQS_MESSAGE} \
    | jp.py 'Messages[].ReceiptHandle' \
    | sed 's/[]\"\[]//g' \
  ) \
) \
  && echo ${sqs_message_receipt_handle}

結果(例):

AQEBxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx=

SQSキューからメッセージを削除します。

変数の確認:

cat << END

  # sqs_queue_url:"https://ap-northeast-1.queue.amazonaws.com/XXXXXXXXXXXX/handson-cli-cloudwatch-1st-queue"
    sqs_queue_url="${sqs_queue_url}"
  # sqs_message_receipt_handle:"AQEBxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx="
    sqs_message_receipt_handle="${sqs_message_receipt_handle}"

END

コマンド:

aws sqs delete-message \
  --queue-url "${sqs_queue_url}" \
  --receipt-handle "${sqs_message_receipt_handle}"

結果(例):

(出力なし)

完了確認¶

本手順の主処理は、以下の完了条件を満たしたときに成功したものとします。

完了条件1: SQSキュー"handson-cli-cloudwatch-1st-queue"のメッセージ数が"0"である。

「SQSキュー"handson-cli-cloudwatch-1st-queue"のメッセージ数が"0"である。」ことを確認します。

コマンド:

aws sqs get-queue-attributes \
  --queue-url ${sqs_queue_url} \
  --attribute-names ApproximateNumberOfMessages \
  --query 'Attributes.ApproximateNumberOfMessages' \
  --output text

結果(例):

完了条件2: メッセージファイル"${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json"が存在する。

「メッセージファイル"${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json"が存在する。」ことを確認します。

コマンド:

ls ${FILE_SQS_MESSAGE}

結果(例):

${HOME}/environment/tmp-handson-cli-cloudwatch-1st/hello_world.json

手順の完了¶

(参考) マネジメントコンソールの確認¶

SQSダッシュボード( https://console.aws.amazon.com/sqs/v2/home )にアクセスします。
右上のリージョンメニューから"東京 "を選択します。

キュー一覧(画面)

検索欄にキュー名"handson-cli-cloudwatch-1st-queue"を入力します。
キュー名"handson-cli-cloudwatch-1st-queue"(リンク)をクリックします。

キュー詳細(画面)

詳細欄下部の"さらに表示"をクリックします。
"利用可能なメッセージ"が"0"であることを確認します。