boto3 在 SNS 中发布消息

Question

我想运行一个脚本来向我的 sns 主题发布消息。我遵循了文档，我的代码是这样的：

import boto3

client = boto3.client('sns')

response = client.publish(
    TopicArn='my topic arn',    
    Message='ptt message '
)
print("Response: {}".format(response))

它会打印响应 json，但在我的 AWS SNS 控制台中没有看到任何消息。作为这个 sns 的订阅者，我有一个非常基本的 lambda 函数。

lambda 代码：

import json

def lambda_handler(event, context):
    # TODO implement
    return {
        'statusCode': 200,
         'body': json.dumps('Hello from Lambda!') 
    }

如何确定我的消息“ptt message”已成功发布？如何查看？

Answer 1

对于集成测试，您可以为您的 SNS 主题配置交付状态日志记录。在 SNS 的 GUI 中有一个简单的设置。这会将订阅触发器的日志导出到 CloudWatch。

其次，您的 Lambda 没有对事件执行任何操作，因此您的“ptt 消息保留在“事件”字典中。例如，您可以记录您的事件并查看实际消息正文所在的结构。

import logging

def lambda_handler(event, context):
    logging.info(event)
    ...

为了查看 Lambda 是由订阅触发的，您可以打开 CloudWatch Logs，找到 AWS 为您的 Lambda 自动创建的 LogGroup（其中包含函数的名称）并搜索 Log Group。 “最后 X 分钟” 有舒适的过滤器。

为了测试这种集成，如果感觉比运行脚本更方便，您还可以从 Web 界面将测试消息发布到 SNS 主题。