AWS SDK SNS Examples: Topics, Subscriptions, Publish आणि Filters (Python, PHP, Node.js)

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

1. मोठं चित्र: station announcement

हे का लागतं?

Train उशिरा आली की एक announcement प्रत्येक speaker, app आणि display board वर एकदम जाते. Announcer प्रत्येक प्रवाशाला फोन करत नाही. SNS topic म्हणजे announcement system; subscribers म्हणजे speakers.

हे काय आहे?

TopicArn ला एकदा Publish; SNS प्रत्येक confirmed subscription ला पोचवतो. Subscription वरची filter policy message attributes match करते म्हणजे प्रत्येकाला हवं तेच मिळतं.

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

2. Topic बनवा

हे का लागतं?

Emma Manchester–Leeds line आणि Arjun मुंबई suburban trains चे operations बघतात; दोघांना एक alerts channel हवा.

हे काय आहे?

CreateTopic idempotent आहे: तेच नाव तोच TopicArn देतं.

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

1. Python (boto3).

import boto3, json
sns = boto3.client("sns", region_name="eu-west-2")
arn = sns.create_topic(Name="train-delays", Tags=[{"Key": "team", "Value": "ops"}])["TopicArn"]
print(arn)

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays

2. Node.js (v3).

import { SNSClient, CreateTopicCommand } from "@aws-sdk/client-sns";
const sns = new SNSClient({ region: "eu-west-2" });
const { TopicArn } = await sns.send(new CreateTopicCommand({ Name: "train-delays" }));
console.log(TopicArn);

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays

3. PHP (v3).

<?php
require "vendor/autoload.php";
$sns = new Aws\Sns\SnsClient(["region" => "eu-west-2"]);
$arn = $sns->createTopic(["Name" => "train-delays"])["TopicArn"];
echo $arn, PHP_EOL;

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays

4. Verify: topics list.

aws sns list-topics --region eu-west-2 --query "Topics[?contains(TopicArn,'train')].TopicArn" --output text

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays

3. Email आणि queue subscribe

हे का लागतं?

Emma ला email हवा; मुंबई passenger app SQS queue मधून वाचतं.

हे काय आहे?

Email subscription link click होईपर्यंत PendingConfirmation. Queue policy sns.amazonaws.com ला परवानगी देत असेल तर SQS लगेच confirm.

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

1. Python: email subscribe.

r = sns.subscribe(TopicArn=arn, Protocol="email",
    Endpoint="emma@rail.example.co.uk", ReturnSubscriptionArn=True)
print(r["SubscriptionArn"])

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays:4a1b...  (pending until Emma clicks Confirm)

2. Node.js: raw delivery सह SQS queue.

import { SubscribeCommand } from "@aws-sdk/client-sns";
const r = await sns.send(new SubscribeCommand({
  TopicArn, Protocol: "sqs",
  Endpoint: "arn:aws:sqs:eu-west-2:123456789012:mumbai-app",
  Attributes: { RawMessageDelivery: "true" }, ReturnSubscriptionArn: true,
}));
console.log(r.SubscriptionArn);

अपेक्षित output:

arn:aws:sns:eu-west-2:123456789012:train-delays:9c7d...

3. PHP: topic ला queue मध्ये send ची परवानगी.

<?php
$sqs = new Aws\Sqs\SqsClient(["region" => "eu-west-2"]);
$policy = ["Version" => "2012-10-17", "Statement" => [[
  "Effect" => "Allow", "Principal" => ["Service" => "sns.amazonaws.com"],
  "Action" => "sqs:SendMessage", "Resource" => "arn:aws:sqs:eu-west-2:123456789012:mumbai-app",
  "Condition" => ["ArnEquals" => ["aws:SourceArn" => $arn]]]]];
$sqs->setQueueAttributes(["QueueUrl" => $queueUrl, "Attributes" => ["Policy" => json_encode($policy)]]);
echo "policy set", PHP_EOL;

अपेक्षित output:

policy set

4. Verify: topic च्या subscriptions.

aws sns list-subscriptions-by-topic --topic-arn $ARN --query "Subscriptions[].[Protocol,SubscriptionArn]" --output text

अपेक्षित output:

email   PendingConfirmation
sqs     arn:aws:sns:eu-west-2:123456789012:train-delays:9c7d...

4. Publish आणि filter

हे का लागतं?

मुंबई प्रवाशांना Manchester delays नकोत, आणि फक्त 10 मिनिटांपेक्षा जास्त delays Emma ला email व्हावेत.

हे काय आहे?

MessageAttributes सह publish; प्रत्येक subscription वर FilterPolicy. Numeric आणि string matching चालतं.

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

1. Python: email subscription वर filter.

sns.set_subscription_attributes(SubscriptionArn=email_sub,
    AttributeName="FilterPolicy",
    AttributeValue=json.dumps({"city": ["manchester"], "minutes": [{"numeric": [">", 10]}]}))
print("filter ok")

अपेक्षित output:

filter ok

2. Node.js: मुंबई delay publish.

import { PublishCommand } from "@aws-sdk/client-sns";
const r = await sns.send(new PublishCommand({
  TopicArn, Subject: "Delay",
  Message: JSON.stringify({ train: "Virar fast 08:12", minutes: 15 }),
  MessageAttributes: {
    city: { DataType: "String", StringValue: "mumbai" },
    minutes: { DataType: "Number", StringValue: "15" } },
}));
console.log(r.MessageId);

अपेक्षित output:

e2a1c0d4-5b6f-5a0e-9d7c-1f2e3d4c5b6a  (queue gets it, Emma does not)

3. PHP: Manchester delay publish.

<?php
$r = $sns->publish(["TopicArn" => $arn, "Subject" => "Delay: 07:45 to Leeds",
  "Message" => "The 07:45 to Leeds is 22 minutes late. Refund up to £8.40.",
  "MessageAttributes" => [
    "city" => ["DataType" => "String", "StringValue" => "manchester"],
    "minutes" => ["DataType" => "Number", "StringValue" => "22"]]]);
echo $r["MessageId"], PHP_EOL;

अपेक्षित output:

7b3f...  (Emma gets the email)

4. Verify: queue वरचा message वाचा.

aws sqs receive-message --queue-url $MUMBAI_URL --wait-time-seconds 10 --query "Messages[0].Body" --output text

अपेक्षित output:

{"train":"Virar fast 08:12","minutes":15}

5. SMS पाठवा

हे का लागतं?

फोनवर booking केलेल्या पुण्यातल्या एका प्रवाशाला text, topic नको.

हे काय आहे?

E.164 format मध्ये PhoneNumber सह publish. Accounts SMS sandbox मध्ये सुरू होतात, आधी number verify करा; alerts साठी SMSType Transactional.

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

1. Python.

r = sns.publish(PhoneNumber="+919800012345",
    Message="Deccan Queen delayed 20 min. New dep 07:35.",
    MessageAttributes={"AWS.SNS.SMS.SMSType": {"DataType": "String", "StringValue": "Transactional"}})
print(r["MessageId"])

अपेक्षित output:

0c9a2f1e-...

2. Node.js.

const r = await sns.send(new PublishCommand({ PhoneNumber: "+447700900123", Message: "Your 07:45 to Leeds is now 08:07." }));
console.log(r.MessageId);

अपेक्षित output:

3d8e...

3. PHP: sandbox number verify साठी जोडा.

<?php
$sns->createSMSSandboxPhoneNumber(["PhoneNumber" => "+919800012345", "LanguageCode" => "en-US"]);
echo "OTP sent", PHP_EOL;

अपेक्षित output:

OTP sent

4. Verify: sandbox status.

aws sns get-sms-sandbox-account-status --region eu-west-2

अपेक्षित output:

{"IsInSandbox": true}

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

हे का लागतं?

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

हे काय आहे?

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

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

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

हे का लागतं?

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

हे काय आहे?

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

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

1. Topic delete करा (subscriptions पण जातात).

aws sns delete-topic --topic-arn $ARN --region eu-west-2

अपेक्षित output:

(no output means success)

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

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

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

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