amazon-sns 相关问题

Amazon Simple Notification Service（Amazon SNS）是一种Web服务，可以轻松地从云中设置，操作和发送通知。它为开发人员提供了高度可扩展，灵活且经济高效的功能，可以从应用程序发布消息并立即将其提供给订阅者或其他应用程序。它旨在使开发人员更轻松地进行Web规模计算。

从 AWS Lambda 发布到 SNS 时超时

我尝试通过 Lambda 函数调用将一些数据发布到 SNS，但它似乎不起作用。我的功能代码是 - 公共类 Handler 实现 RequestHandler 我尝试通过 Lambda 函数调用将一些数据发布到 SNS，但它似乎不起作用。我的功能代码是 - public class Handler implements RequestHandler<DynamodbEvent, Void> { private static final String SNS_TOPIC_ARN = "arn:aws:sns:us-west-2:account_number:function_name"; @Override public Void handleRequest(DynamodbEvent dynamodbEvent, Context context) { LambdaLogger logger = context.getLogger(); AmazonSNSClient snsClient = new AmazonSNSClient(new DefaultAWSCredentialsProviderChain()); snsClient.setRegion(Region.getRegion(Regions.US_WEST_2)); for (DynamodbStreamRecord record : dynamodbEvent.getRecords()) { Map<String, AttributeValue> newImage = record.getDynamodb().getNewImage(); if (newImage == null) { continue; } String sensorId = newImage.get("sensorID").getS(); long timestamp = Long.parseLong(newImage.get("timestamp").getS()); double temperature = Double.parseDouble(newImage.get("payload").getM().get("temp").getN()); String data = sensorId + " " + timestamp + " " + temperature; logger.log(data); PublishRequest publishRequest = new PublishRequest(SNS_TOPIC_ARN, data); PublishResult publishResult = snsClient.publish(publishRequest); logger.log("Publish Successful " + publishResult.getMessageId()); } snsClient.shutdown(); return null; } } 此调用会导致超时（10 秒）并且 lambda 调用失败。如果我注释掉 SNS 发布部分，即如果我只记录从 DynamoDB 收到的数据，它就可以正常工作。一旦添加SNS发布代码，就会超时。 CloudWatch 中记录的超时消息是 - START RequestId: 8db74187-459b-42c5-8a06-b3a74873b236 Version: $LATEST END RequestId: 8db74187-459b-42c5-8a06-b3a74873b236 REPORT RequestId: 8db74187-459b-42c5-8a06-b3a74873b236 Duration: 10001.66 ms Billed Duration: 10000 ms Memory Size: 128 MB Max Memory Used: 37 MB Task timed out after 10.00 seconds 我拥有所有适当的权限，并且我可以使用在我的 PC 上运行的以下代码发布到 SNS - PublishRequest publishRequest = new PublishRequest(SNS_TOPIC_ARN, data); PublishResult publishResult = snsClient.publish(publishRequest); System.out.println("Publish Successful " + publishResult.getMessageId()); 我也尝试过使用 AmazonSNSAsyncClient 而不是 AmazonSNSClient，它给出了相同的结果。我在这里缺少什么？好吧，既然评论我问题的人都没有回答，那我自己来回答吧。将内存使用量增加到 256 MB，并将超时时间增加到 30 秒似乎已经解决了问题。增加为 Lambda 操作分配的内存量。增加分配给 lambda 函数的内存也对我有用（此设置位于 lambda 控制台的基本设置下）。这让我抓狂 - 我对 2 个具有相同配置的不同 lambda 函数使用相同的 JAR 文件，并且 SNS 调用对其中一个有效，但对另一个超时。令人抓狂！就我而言，问题是网络问题。如果 VPC 缺少 NAT 网关，VPC 中的 lambda 通常无法访问网络。这阻止了 SNS 的触发。您可以通过为 Amazon SNS 创建 Amazon VPC 终端节点来解决此问题：在 Amazon VPC 控制台中，创建一个新终端节点选择 AWS 服务 com.amazonaws..sns 选择您的 lambda vpc、所有子网、安全组建立此 AWS PrivateLink 后，来自我的 Lambda 函数的 SNS 通知立即生效，无需对 SNS 或 Lambda 本身进行进一步更改。

java amazon-web-services amazon-sns aws-lambda aws-java-sdk

回答 4 投票 0

通过CloudWatch监控SQS消息

我收到了SNS通知，并且我已经订阅了SQS。我可以轮询我的消息并查看其内容。消息的内容包括自动化的通过/失败状态。 ...

amazon-cloudwatch amazon-sqs amazon-sns

回答 1 投票 0

使用 amazon SNS 向多个用户端点发送推送通知

我有一个功能，可以获取设备端点列表，并且我需要向该列表中的所有设备发送推送通知。该列表是动态的，因为它可以包含任意数量的...

amazon-web-services push-notification amazon-sns

回答 2 投票 0

SalesForce - AWS SNS 集成参考

有 salesforce 和 Amazon SNS 集成的重新参考示例吗？