AWS: SQS cli demo

# SQS demo

## Creación de la cola

export AWS_DEFAULT_REGION=eu-west-1
aws configure
name=curso_$RANDOM
echo The queue name is $name.

aws sqs create-queue --queue-name $name

qurl=$(aws sqs get-queue-url --queue-name $name --query QueueUrl --output text)
aws sqs send-message --queue-url $qurl --message-body "Pole!"

aws sqs receive-message --queue-url $qurl --max-number-of-message 1

#aws sqs delete-queue --queue-url $qurl

## producer.sh

cat << EOF > producer.sh
#!/bin/sh

name=curso_ciberado_sqs
echo Using queue $name
qurl=`aws sqs get-queue-url --queue-name $name --query QueueUrl --output text`
echo Qeueu url: $qurl
for i in `seq 1 1000`; do
    aws sqs send-message --queue-url $qurl --message-body "This is message $i."
    sleep 1
done
EOF

## consumer.sh

cat << EOF > consumer.sh
#!/bin/bash

wget https://github.com/stedolan/jq/releases/download/jq-1.6/jq-linux64
mv jq-linux64 jq
chmod +x jq

name=curso_ciberado_sqs
echo Using queue $name
qurl=$(aws sqs get-queue-url --queue-name $name --query QueueUrl --output text)
echo Queue url: $qurl
while true; do
    msg=$(aws sqs receive-message --queue-url $qurl --max-number-of-message 1)
    handler=$(echo "$msg" | jq -r .Messages[0].ReceiptHandle)
    body=$(echo "$msg" | jq -r .Messages[0].Body)
    echo "$body"
    aws sqs delete-message --queue-url $qurl --receipt-handle $handler

    sleep 2
done
EOF