خودکار کردن اعلان پیام متنی (SMS) با استفاده از SNS و AWS lambda

Summarize this content to 400 words in Persian Lang
معرفی:خودکار کردن اعلان‌های پیامکی با استفاده از AWS Lambda و SNS (سرویس اعلان ساده) روشی قدرتمند برای آگاه کردن کاربران در مورد رویدادهای مهم یا به‌روزرسانی‌های برنامه شما است. AWS Lambda به شما این امکان را می دهد که کد را بدون تهیه یا مدیریت سرورها اجرا کنید، در حالی که SNS به شما امکان می دهد پیام ها را به تعداد زیادی از گیرندگان به طور همزمان ارسال کنید.

کار کردن:این منبعی است که فایل در آن آپلود می شود، این سطل s3 برای راه اندازی AWS lambda پیکربندی شده است. lambda حاوی یک کد پایتون است که مکانیسم خواندن رویداد را انجام می دهد و پیام های کاملاً قاب شده را در موضوع SNS منتشر می کند. برای موضوع SNS ما تلفن می سازیم و مشترک موضوع SNS می شویم و پیام هایی منتشر می شود که متنی در مورد رویداد دریافت می کند.

معماری

AWS Amazon S3:

نام را به سطل ارائه دهید.
یک سطل ایجاد کنید

2.یک تابع لامبدا ایجاد کنید

نام تابع را ارائه دهید
از زمان اجرا به عنوان پایتون 3.9 استفاده کنید
از نقش موجود استفاده کنید

برای تغییر تنظیمات روی تنظیمات کلیک کنید

اندازه حافظه را تغییر دهید
برای کاهش هزینه، تایم اوت را تغییر دهید
ذخیره را کلیک کنید

ماشه کلیک کنید
افزودن ماشه را انتخاب کنید 's3 bucket'
روی انواع رویداد کلیک کنید و “همه شیء ایجاد رویدادها” را انتخاب کنید.
روی افزودن کلیک کنید

کد لامبدا را در منبع کد قرار دهید.

import boto3

topic_arn = “”
def send_sns(message, subject):
try:
client = boto3.client(“sns”)
result = client.publish(TopicArn=topic_arn, Message=message, Subject=subject)
if result[‘ResponseMetadata’][‘HTTPStatusCode’] == 200:
print(result)
print(“Notification send successfully..!!!”)
return True
except Exception as e:
print(“Error occured while publish notifications and error is : “, e)
return True

def lambda_handler(event, context):
print(“event collected is {}”.format(event))
for record in event[‘Records’] :
s3_bucket = record[‘s3’][‘bucket’][‘name’] print(“Bucket name is {}”.format(s3_bucket))
s3_key = record[‘s3’][‘object’][‘key’] print(“Bucket key name is {}”.format(s3_key))
from_path = “s3://{}/{}”.format(s3_bucket, s3_key)
print(“from path {}”.format(from_path))
message = “The file is uploaded at S3 bucket path {}”.format(from_path)
subject = “Processes completion Notification”
SNSResult = send_sns(message, subject)
if SNSResult :
print(“Notification Sent..”)
return SNSResult
else:
return False

وارد حالت تمام صفحه شوید

از حالت تمام صفحه خارج شوید

کد را نصب کنید و کد را آزمایش کنید.

3.موضوع SNS را ایجاد کنید

روی موضوع استاندارد SNS کلیک کنید.
یک نام برای موضوع SNS ارائه دهید.
یک موضوع ایجاد کنید

کد arn تولید می شود این کد قبل از استقرار و آزمایش کد در تابع لامبدا چسبانده می شود.

4.ایجاد مشترکین:

ARN را ارائه کنید
پروتکل (پیامک) را انتخاب کنید
نقطه پایانی SNS – شماره تلفن
بر روی پیامک (SMS) کلیک کنید

روی افزودن شماره تلفن در “شماره تلفن مقصد جعبه ایمنی” کلیک کنید
شماره تلفن را اضافه کنید ، کشور را انتخاب کرده و تأیید کنید.

شماره تلفن تایید شده است

شماره تلفن مشترک:

موضوع را انتخاب کنید
انتخاب شماره تلفن اس ام اس پس از تایید ظاهر می شود.

یک فایل ساختگی را در نقطه ماشه یعنی S3 آپلود کنید و اعلان به عنوان یک پیام متنی به تلفن ارسال می شود.

import boto3

topic_arn = ""
def send_sns(message, subject):
    try:
        client = boto3.client("sns")
        result = client.publish(TopicArn=topic_arn, Message=message, Subject=subject)
        if result['ResponseMetadata']['HTTPStatusCode'] == 200:
            print(result)
            print("Notification send successfully..!!!")
            return True
    except Exception as e:
        print("Error occured while publish notifications and error is : ", e)
        return True

def lambda_handler(event, context):
    print("event collected is {}".format(event))
    for record in event['Records'] :
        s3_bucket = record['s3']['bucket']['name']
        print("Bucket name is {}".format(s3_bucket))
        s3_key = record['s3']['object']['key']
        print("Bucket key name is {}".format(s3_key))
        from_path = "s3://{}/{}".format(s3_bucket, s3_key)
        print("from path {}".format(from_path))
        message = "The file is uploaded at S3 bucket path {}".format(from_path)
        subject = "Processes completion Notification"
        SNSResult = send_sns(message, subject)
        if SNSResult :
            print("Notification Sent..") 
            return SNSResult
        else:
            return False