AWS 消息通知系统 SNS

ops/2024/9/23 7:48:37/

AWS 消息通知系统 SNS

  • 引言
  • 什么是 AWS SNS
  • SNS 的工作原理
  • SNS 的主要应用场景
  • 示例:创建 SNS 主题和订阅
    • 使用 AWS 管理控制台
    • 使用 AWS CLI
    • 使用 AWS SDK (Python Boto3)
  • 示例 CloudWatch 如何通过 SNS 发送告警通知

引言

《AWS 监控和管理服务 CloudWatch》有介绍 CloudWatch 收集日志和监控指标,接下来就要发送警告消息了,这里就用到 AWS 另外一个消息发布/订阅服务 SNS (Simple Notification Service)

SNS_3">什么是 AWS SNS

Amazon SNS (Simple Notification Service) 是一项高度可扩展、灵活且完全托管的消息发布/订阅服务。它允许应用程序、服务和设备之间以近乎实时的方式发送和接收通知或消息。开发者可以通过 SNS 轻松地向多个订阅者发布消息,并根据需要发送给不同类型的端点。

核心概念

  1. 主题(Topic):
    SNS 主题是消息的分类渠道,发布者将消息发送到主题,然后 SNS 会将消息广播给所有订阅者。
    每个 SNS 主题都有一个唯一的 ARN(Amazon Resource Name)标识符。

  2. 订阅者(Subscriber):
    订阅者是接收 SNS 主题消息的实体。可以是不同的端点或协议,包括:
    HTTP/HTTPS:通过 HTTP/HTTPS 端点接收消息。
    Email:通过电子邮件接收通知。
    SMS:通过短信接收通知。
    SQS:将消息发送到 Amazon SQS 队列。
    Lambda:触发 Lambda 函数执行。
    Application:推送通知到移动设备应用(通过 Firebase、APNS 等)。

  3. 发布者(Publisher):
    发布者是发送消息到 SNS 主题的实体。它可以是 AWS 服务(如 CloudWatch 警告、Lambda)或任何外部应用程序。

  4. 消息:
    发布者将消息发布到主题,消息会立即转发给所有订阅了该主题的订阅者。SNS 支持文本消息和 JSON 格式的消息。

SNS 的特点和优势

  • 高可用性:SNS 是完全托管的服务,自动扩展以满足消息发布和订阅的需求。
  • 高吞吐量:支持大规模、高速的消息发布和传递。
  • 多协议支持:SNS 支持通过多种协议(HTTP、Email、SMS、SQS、Lambda 等)发送通知。
  • 按需计费:SNS 按实际使用量计费,用户仅需为发布的消息和交付的通知付费。
  • 跨区域通知:SNS 可以在 AWS 跨区域之间发送消息,确保跨地域服务之间的通信。

SNS__32">SNS 的工作原理

  1. 创建 SNS 主题:用户创建一个 SNS 主题,用于管理发布者和订阅者之间的消息通信。
  2. 订阅主题:用户或系统可以订阅该主题,可以选择不同的通信协议(例如 HTTP、Email、SMS 等)。
  3. 发布消息:发布者将消息发送到 SNS 主题。
  4. 通知分发:SNS 将消息自动分发到所有订阅者。根据订阅者的协议类型,SNS 将以相应的方式发送消息。

SNS__38">SNS 的主要应用场景

  1. 分布式系统通知: 在分布式系统中,服务组件可以通过 SNS 通知其他组件事件或状态的变化,例如资源预警或服务状态更新。
  2. 报警和监控通知: 结合 Amazon CloudWatch,当监控指标超出设定的阈值时,CloudWatch 警告可以通过 SNS 发送电子邮件、短信或其他类型的通知。
  3. 消息推送: SNS 可以用于向移动设备发送推送通知,如 iOS 和 Android 设备上的应用程序更新或系统消息。
  4. 跨系统通信: 不同系统间需要通过消息传递进行异步通信时,SNS 可以作为中介,确保消息从发送方传递到接收方,甚至可以和 SQS 队列结合使用。
  5. 无服务器架构的事件驱动: 使用 SNS 触发 AWS Lambda 函数,实现无服务器架构的事件驱动处理,例如在某个事件发生时自动执行任务。

SNS__44">示例:创建 SNS 主题和订阅

使用 AWS 管理控制台

  1. 登录到 AWS 管理控制台。
  2. 打开 SNS 控制台。
  3. 在左侧导航栏中,选择“Topics”。
  4. 点击“Create topic”按钮。
  5. 选择“Standard”类型,输入主题名称,然后点击“Create topic”。
  6. 选择刚刚创建的主题,点击“Create subscription”按钮。
  7. 选择协议(例如 Email),并输入订阅端点(例如电子邮件地址)。
  8. 点击“Create subscription”。

使用 AWS CLI

# 创建 SNS 主题
aws sns create-topic --name MyTopic# 获取主题 ARN
TOPIC_ARN=$(aws sns list-topics --query "Topics[?contains(TopicArn, 'MyTopic')].TopicArn" --output text)# 创建订阅
aws sns subscribe --topic-arn $TOPIC_ARN --protocol email --notification-endpoint example@example.com# 发布消息
aws sns publish --topic-arn $TOPIC_ARN --message "Hello, this is a test message!"

使用 AWS SDK (Python Boto3)

import boto3# 创建 SNS 客户端
sns_client = boto3.client('sns')# 创建 SNS 主题
response = sns_client.create_topic(Name='MyTopic')
topic_arn = response['TopicArn']# 创建订阅
sns_client.subscribe(TopicArn=topic_arn,Protocol='email',Endpoint='example@example.com'
)# 发布消息
sns_client.publish(TopicArn=topic_arn,Message='Hello, this is a test message!'
)

CloudWatch__SNS__95">示例 CloudWatch 如何通过 SNS 发送告警通知

要通过 Amazon CloudWatch 使用 SNS 发送告警通知,可以按照以下步骤操作:

  1. 创建 SNS 主题:
    登录到 AWS 管理控制台。
    打开 Amazon SNS 控制台。
    创建一个新的 SNS 主题,并记下主题的 ARN(Amazon Resource Name)。
  2. 订阅 SNS 主题:
    SNS 控制台中,选择刚刚创建的主题。
    创建一个新的订阅,选择协议(如 Email、SMS 等),并输入相应的终端(如电子邮件地址或电话号码)。
  3. 创建 CloudWatch 警报:
    打开 Amazon CloudWatch 控制台。
    导航到“警报”部分,然后选择“创建警报”。
    选择一个现有的指标或创建一个新的指标来监控。
    配置警报条件(如阈值、时间段等)。
    在“警报操作”部分,选择“添加通知”。
    选择 SNS 主题,并选择之前创建的 SNS 主题。
  4. 配置警报动作:
    配置警报的状态变化时(如进入警报状态、OK 状态等)发送通知。
    完成警报配置并保存。

以下是一个示例 Python 脚本,使用 Boto3 库来创建 SNS 主题、订阅和 CloudWatch 警报:

import boto3# 创建 SNS 客户端
sns_client = boto3.client('sns')# 创建 SNS 主题
response = sns_client.create_topic(Name='MyTopic')
topic_arn = response['TopicArn']# 订阅 SNS 主题
sns_client.subscribe(TopicArn=topic_arn,Protocol='email',  # 或 'sms', 'lambda', 'sqs' 等Endpoint='your-email@example.com'  # 替换为您的电子邮件地址或电话号码
)# 创建 CloudWatch 客户端
cloudwatch_client = boto3.client('cloudwatch')# 创建 CloudWatch 警报
cloudwatch_client.put_metric_alarm(AlarmName='MyAlarm',MetricName='CPUUtilization',Namespace='AWS/EC2',Statistic='Average',Period=300,EvaluationPeriods=1,Threshold=70.0,ComparisonOperator='GreaterThanThreshold',AlarmActions=[topic_arn],Dimensions=[{'Name': 'InstanceId','Value': 'i-1234567890abcdef0'  # 替换为您的实例 ID},]
)

以下是一个示例 Python 脚本,使用 Boto3 库来创建 SNS 主题、订阅、CloudWatch Logs 过滤器和警报:

import boto3# 创建 SNS 客户端
sns_client = boto3.client('sns')# 创建 SNS 主题
response = sns_client.create_topic(Name='MyLogErrorTopic')
topic_arn = response['TopicArn']# 订阅 SNS 主题
sns_client.subscribe(TopicArn=topic_arn,Protocol='email',  # 或 'sms', 'lambda', 'sqs' 等Endpoint='your-email@example.com'  # 替换为您的电子邮件地址或电话号码
)# 创建 CloudWatch Logs 客户端
logs_client = boto3.client('logs')# 创建日志组和日志流(如果尚未创建)
log_group_name = 'MyLogGroup'
log_stream_name = 'MyLogStream'
logs_client.create_log_group(logGroupName=log_group_name)
logs_client.create_log_stream(logGroupName=log_group_name, logStreamName=log_stream_name)# 创建指标过滤器
filter_name = 'ErrorFilter'
filter_pattern = 'ERROR'
metric_name = 'ErrorCount'
metric_namespace = 'MyNamespace'logs_client.put_metric_filter(logGroupName=log_group_name,filterName=filter_name,filterPattern=filter_pattern,metricTransformations=[{'metricName': metric_name,'metricNamespace': metric_namespace,'metricValue': '1'},]
)# 创建 CloudWatch 客户端
cloudwatch_client = boto3.client('cloudwatch')# 创建 CloudWatch 警报
cloudwatch_client.put_metric_alarm(AlarmName='LogErrorAlarm',MetricName=metric_name,Namespace=metric_namespace,Statistic='Sum',Period=300,EvaluationPeriods=1,Threshold=1.0,ComparisonOperator='GreaterThanOrEqualToThreshold',AlarmActions=[topic_arn]
)

http://www.ppmy.cn/ops/114149.html

相关文章

面试-设计模式

策略模式 定义了一组算法,分别封装起来,这些算法直接可以相互替换 设计模式的开闭原则:对修改关闭,对扩展开放 装饰模式 将某种算法作为一个装饰品添加到对象身上,同时可以自由穿戴更换装饰品 两个主要的角色&…

Docker 笔记

Docker 常用命令 列出全部的镜像: docker image ls (或是 docker images) Docker 教程: https://yeasy.gitbook.io/docker_practice/basic_concept/container 笔记 镜像(Image)和容器(Container)的关系,就像 类 和…

STL简介

在了解了C中的类和对象以及内存管理基本的知识后接下来我们将进入STL的学习,在此我们在本篇会先了解STL的由来以及大致了解STL的组成,接下来在之后的篇章中我将依次来学string、vector等,学习完STL之后相信你会进一步了解C的魅力所在。接下来…

Docker学习笔记(三)存储与卷

挂载机制介绍 我们都知道,默认下,Docker容器与宿主机是完全隔离的,这种特性使得我们创建与删除容器都变得更方便,不需要再去删除宿主机上容器遗留下来的痕迹。   但是,当我们使用数据库一类需要持久化数据、共享数据…

【STL】 set 与 multiset:基础、操作与应用

在 C 标准库中&#xff0c;set 和 multiset 是两个非常常见的关联容器&#xff0c;主要用于存储和管理具有一定规则的数据集合。本文将详细讲解如何使用这两个容器&#xff0c;并结合实例代码&#xff0c;分析其操作和特性。 0.基础操作概览 0.1.构造&#xff1a; set<T&…

面试金典题6

字符串压缩。利用字符重复出现的次数&#xff0c;编写一种方法&#xff0c;实现基本的字符串压缩功能。比如&#xff0c;字符串aabcccccaaa会变为a2b1c5a3。若“压缩”后的字符串没有变短&#xff0c;则返回原先的字符串。你可以假设字符串中只包含大小写英文字母&#xff08;a…

统信服务器操作系统【刻录镜像制作U盘启动盘的工具】

统信服务器操作系统各版本上刻录镜像制作U盘启动盘的工具方案 文章目录 应用场景一、问题现象二、问题分析解决方案应用场景 硬件/整机信息:全平台 CPU架构:全架构 OS版本信息:服务器a版,e版,d版(其中d版遇到的刻录类问题较少) 软件信息:dd工具、Fedora Media Writer工…

滚雪球学SpringCloud[4.1讲]: Spring Cloud Gateway详解

全文目录&#xff1a; 前言API Gateway的概念与作用什么是API Gateway&#xff1f;API Gateway的作用&#xff1a; Spring Cloud Gateway的核心特性配置Spring Cloud Gateway1. 引入依赖2. 基本路由配置3. 路由与过滤器的使用示例&#xff1a;路径匹配与过滤器 4. 动态路由与负…