sqs-cmd

create

aws sqs create-queue --queue-name sqs2 --query 'QueueUrl' --output text

send and receive messages

使用 send-message 发送消息，将保持 lambda 并发为 1

with curl

# send message to sqs anonymously
message=test
sqs_url=https://sqs.ap-northeast-2.amazonaws.com/123456789012/public-queue-seoul
curl -d "Action=SendMessage&Version=2011-10-01&MessageBody=${message}" ${sqs_url}

# ReceiveMessage
curl -d "Action=ReceiveMessage&Version=2011-10-01" ${sqs_url}

with awscli

# send 100 message to sqs
for i in `seq 1 99` ; do 
  aws sqs send-message  \
    --queue-url "https://cn-northwest-1.queue.amazonaws.com.cn/123456789012/sqs-std1" \
    --message-body "message$i"
done

# retrieve 1 message
aws sqs receive-message \
  --queue-url https://cn-northwest-1.queue.amazonaws.com.cn/123456789012/sqs-std1


# one message sample
{
    "Messages": [
        {
            "Body": "aaaaa",
            "ReceiptHandle": "===ReceiptHandleString===",
            "MD5OfBody": "594f803b380a41396ed63dca39503542",
            "MessageId": "d64a9969-c287-44e3-bac7-5025f61b5b39"
        }
    ]
}

# delete message
aws sqs delete-message \
  --queue-url https://cn-northwest-1.queue.amazonaws.com.cn/123456789012/sqs-std1 \
  --receipt-handle "===ReceiptHandleString==="

send-message-batch

使用 batch 发送消息，会使得 lambda 并发与 message 数量一致，如下将并发 2 个 lambda

• messages.json
  

  [
    {
      "Id": "Message1",
      "MessageBody": "This is the first message",
      "DelaySeconds": 0,
      "MessageAttributes": {
        "Attribute1": {
          "DataType": "String",
          "StringValue": "Value1"
        }
      }
    },
    {
      "Id": "Message2",
      "MessageBody": "This is the second message",
      "DelaySeconds": 0,
      "MessageAttributes": {
        "Attribute2": {
          "DataType": "String",
          "StringValue": "Value2"
        }
      }
    }
  ]
  

• send message batch
  

  aws sqs send-message-batch --queue-url $sqs_url --entries file://./messages.json
  

scaling behavior for sqs trigger in lambda

https://docs.aws.amazon.com/lambda/latest/dg/services-sqs-scaling.html

• batch size
• batch window
• maximum concurrency