AWS SDK SQS Examples: Messages Send, Receive, Delete आणि DLQs (Python, PHP, Node.js)

By Ravindra Bagale, trainer · LinkedIn · Last updated: 24 October 2026

1. मोठं चित्र: bakery मधला order spike

हे का लागतं?

Counter वर cashier प्रत्येक order slip वर लिहून rail ला लावतो. Bakers मोकळे झाले की slip घेतात. Baker ने slip टाकली तर थोड्या वेळाने ती परत rail वर येते. ती rail म्हणजे SQS: cashier ला oven ची वाट पाहावी लागत नाही.

हे काय आहे?

Receive केलेला message visibility timeout साठी लपतो. त्याआधी ReceiptHandle ने delete केला नाही तर तो परत दिसतो. maxReceiveCount प्रयत्नांनंतर तो DLQ मध्ये जातो.

कसं करायचं (step by step)

2. Queues बनवा

हे का लागतं?

Chloé ला सर्व orders साठी एक queue हवी, आणि Rohan ला FIFO queue हवी म्हणजे एका customer चे payments क्रमाने होतील.

हे काय आहे?

CreateQueue QueueUrl देतो जो पुढच्या सर्व calls ला लागतो. FIFO नाव .fifo ने संपायला हवं.

कसं करायचं (step by step)

1. Python (boto3): long polling सह standard queue.

import boto3
sqs = boto3.client("sqs", region_name="eu-west-3")
url = sqs.create_queue(QueueName="bakery-orders",
    Attributes={"ReceiveMessageWaitTimeSeconds": "20", "VisibilityTimeout": "60"})["QueueUrl"]
print(url)

अपेक्षित output:

https://sqs.eu-west-3.amazonaws.com/123456789012/bakery-orders

2. Node.js (v3): FIFO queue.

import { SQSClient, CreateQueueCommand } from "@aws-sdk/client-sqs";
const sqs = new SQSClient({ region: "ap-south-1" });
const { QueueUrl } = await sqs.send(new CreateQueueCommand({
  QueueName: "payments.fifo",
  Attributes: { FifoQueue: "true", ContentBasedDeduplication: "true" },
}));
console.log(QueueUrl);

अपेक्षित output:

https://sqs.ap-south-1.amazonaws.com/123456789012/payments.fifo

3. PHP (v3): नावावरून queue URL.

<?php
require "vendor/autoload.php";
$sqs = new Aws\Sqs\SqsClient(["region" => "eu-west-3"]);
$url = $sqs->getQueueUrl(["QueueName" => "bakery-orders"])["QueueUrl"];
echo $url, PHP_EOL;

अपेक्षित output:

https://sqs.eu-west-3.amazonaws.com/123456789012/bakery-orders

4. Verify: prefix ने queues list.

aws sqs list-queues --queue-name-prefix bakery --region eu-west-3 --query "QueueUrls" --output text

अपेक्षित output:

https://sqs.eu-west-3.amazonaws.com/123456789012/bakery-orders

3. Messages send करा

हे का लागतं?

Lyon ची प्रत्येक croissant order आणि पुण्याची प्रत्येक ₹450 ची cake order एक message बनते.

हे काय आहे?

Body 256 KB पर्यंत text; JSON पाठवा. SendMessageBatch एकावेळी 10 पर्यंत. FIFO ला MessageGroupId लागतो.

कसं करायचं (step by step)

1. Python: attribute सह एक order.

import json
r = sqs.send_message(QueueUrl=url,
    MessageBody=json.dumps({"order": "LY-101", "item": "croissant", "qty": 12, "total": "€18.00"}),
    MessageAttributes={"shop": {"DataType": "String", "StringValue": "lyon"}})
print(r["MessageId"])

अपेक्षित output:

5fea7756-0ea4-451a-a703-a558b933e274

2. Node.js: एका customer चं FIFO payment.

import { SendMessageCommand } from "@aws-sdk/client-sqs";
const r = await sqs.send(new SendMessageCommand({
  QueueUrl, MessageGroupId: "cust-rohan",
  MessageBody: JSON.stringify({ order: "PN-77", amount: "₹450" }),
}));
console.log(r.MessageId, r.SequenceNumber);

अपेक्षित output:

b1c2d3e4-... 18872039482910000000

3. PHP: तीन orders batch send.

<?php
$entries = [];
foreach (["LY-102", "LY-103", "LY-104"] as $i => $id) {
    $entries[] = ["Id" => "m$i", "MessageBody" => json_encode(["order" => $id])];
}
$r = $sqs->sendMessageBatch(["QueueUrl" => $url, "Entries" => $entries]);
echo count($r["Successful"]), " sent, ", count($r["Failed"] ?? []), " failed", PHP_EOL;

अपेक्षित output:

3 sent, 0 failed

4. Verify: वाट पाहणाऱ्या messages ची संख्या.

aws sqs get-queue-attributes --queue-url $URL --attribute-names ApproximateNumberOfMessages --query Attributes.ApproximateNumberOfMessages --output text

अपेक्षित output:

4

4. Receive, process आणि delete

हे का लागतं?

Lyon मधलं baker app 10 पर्यंत slips घेईल, bake करेल, आणि फक्त पूर्ण झालेल्या काढेल.

हे काय आहे?

WaitTimeSeconds=20 सह ReceiveMessage = long polling: कमी रिकामे calls, कमी खर्च. ह्या receive च्या ReceiptHandle ने delete करा.

कसं करायचं (step by step)

1. Python: worker loop.

while True:
    msgs = sqs.receive_message(QueueUrl=url, MaxNumberOfMessages=10,
        WaitTimeSeconds=20, MessageAttributeNames=["All"]).get("Messages", [])
    if not msgs: break
    for m in msgs:
        body = json.loads(m["Body"])
        print("baking", body["order"])
        sqs.delete_message(QueueUrl=url, ReceiptHandle=m["ReceiptHandle"])

अपेक्षित output:

baking LY-101
baking LY-102
baking LY-103
baking LY-104

2. Node.js: receive आणि batch delete.

import { ReceiveMessageCommand, DeleteMessageBatchCommand } from "@aws-sdk/client-sqs";
const { Messages = [] } = await sqs.send(new ReceiveMessageCommand({ QueueUrl, MaxNumberOfMessages: 10, WaitTimeSeconds: 20 }));
for (const m of Messages) console.log("paid", JSON.parse(m.Body).order);
if (Messages.length) await sqs.send(new DeleteMessageBatchCommand({ QueueUrl,
  Entries: Messages.map((m, i) => ({ Id: String(i), ReceiptHandle: m.ReceiptHandle })) }));

अपेक्षित output:

paid PN-77

3. PHP: हळू कामासाठी visibility timeout वाढवा.

<?php
$r = $sqs->receiveMessage(["QueueUrl" => $url, "WaitTimeSeconds" => 20]);
foreach ($r["Messages"] ?? [] as $m) {
    $sqs->changeMessageVisibility(["QueueUrl" => $url,
        "ReceiptHandle" => $m["ReceiptHandle"], "VisibilityTimeout" => 300]);
    echo "long job ", json_decode($m["Body"])->order, PHP_EOL;
    $sqs->deleteMessage(["QueueUrl" => $url, "ReceiptHandle" => $m["ReceiptHandle"]]);
}

अपेक्षित output:

long job LY-105

4. Verify: queue रिकामी आहे.

aws sqs get-queue-attributes --queue-url $URL --attribute-names ApproximateNumberOfMessages ApproximateNumberOfMessagesNotVisible --output json

अपेक्षित output:

{"Attributes": {"ApproximateNumberOfMessages": "0", "ApproximateNumberOfMessagesNotVisible": "0"}}

5. खराब messages साठी dead-letter queue

हे का लागतं?

Toronto ची एक order तुटक JSON ची आहे आणि प्रत्येक वेळी worker crash करते. ती rail कायम अडवू नये.

हे काय आहे?

दुसरी queue बनवा आणि main queue वर maxReceiveCount सह RedrivePolicy लावा. DLQ तपासा, fix नंतर redrive करा.

कसं करायचं (step by step)

1. Python: DLQ बनवून जोडा.

dlq = sqs.create_queue(QueueName="bakery-orders-dlq")["QueueUrl"]
arn = sqs.get_queue_attributes(QueueUrl=dlq, AttributeNames=["QueueArn"])["Attributes"]["QueueArn"]
sqs.set_queue_attributes(QueueUrl=url, Attributes={"RedrivePolicy": json.dumps(
    {"deadLetterTargetArn": arn, "maxReceiveCount": "3"})})
print("dlq", arn)

अपेक्षित output:

dlq arn:aws:sqs:eu-west-3:123456789012:bakery-orders-dlq

2. Node.js: DLQ मधले messages वाचा.

const dlqUrl = QueueUrl.replace("payments.fifo", "bakery-orders-dlq");
const r = await sqs.send(new ReceiveMessageCommand({ QueueUrl: dlqUrl, MessageAttributeNames: ["All"], AttributeNames: ["ApproximateReceiveCount"] }));
for (const m of r.Messages ?? []) console.log(m.Attributes.ApproximateReceiveCount, m.Body);

अपेक्षित output:

4 {order: "TO-9", total: "$12.50"

3. PHP: source queue मध्ये परत redrive.

<?php
$r = $sqs->startMessageMoveTask([
    "SourceArn" => "arn:aws:sqs:eu-west-3:123456789012:bakery-orders-dlq"]);
echo $r["TaskHandle"] ? "redrive started" : "no task", PHP_EOL;

अपेक्षित output:

redrive started

4. Verify: redrive policy तपासा.

aws sqs get-queue-attributes --queue-url $URL --attribute-names RedrivePolicy --query Attributes.RedrivePolicy --output text

अपेक्षित output:

{"deadLetterTargetArn":"arn:aws:sqs:eu-west-3:123456789012:bakery-orders-dlq","maxReceiveCount":"3"}

6. हाच call Java, Go, .NET आणि CLI मध्ये

हे का लागतं?

Teams अनेकदा भाषा मिसळतात. Python, PHP आणि Node.js मध्ये call समजला की बाकीचे SDKs म्हणजे तोच API, फक्त syntax वेगळा.

हे काय आहे?

सगळे SendMessage API call करतात. Terminal मधून पटकन test करायला CLI ओळ वापरा.

कसं करायचं (step by step)

7. काहीही खर्च चालू राहू नये म्हणून cleanup

हे का लागतं?

चालू ठेवलेले lab resources पैसे खातात आणि security risk बनतात.

हे काय आहे?

उलट्या क्रमाने delete करा: आधी children, मग parents.

कसं करायचं (step by step)

1. दोन्ही queues delete करा.

aws sqs delete-queue --queue-url $URL --region eu-west-3
aws sqs delete-queue --queue-url $DLQ_URL --region eu-west-3

अपेक्षित output:

(no output means success)

8. मुलाखत प्रश्न आणि उत्तरं

उजळणी, तुलना आणि मुलाखत cards

हा lesson काही मिनिटांत revise करा. Cards phone वर save करा किंवा PNG download करा. प्रत्येक card वरचा QR हा lesson उघडतो.

अजून cards: Ravi Sir's Cards.