amazon-sns 相关问题

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

我有一个奇怪的问题。 my sns-> sqs sqs sqs sqs with filter策略(任何东西)都可以正常工作。

我似乎能够通过base64编码自己并以字符串类型的方式发送值来解决它。

回答 1 投票 0



/sns

回答 1 投票 0


为什么AWS SNS过滤不忽略未知消息属性?

AWS文档说,未知消息属性被过滤器策略忽略了。 当Amazon SNS根据订阅过滤器策略评估消息属性时,它忽略了消息

回答 2 投票 0

我如何通过fifosns

private final NotificationMessagingTemplate notificationMessagingTemplate; public void send(final T payload, final Object groupId) { final ImmutableMap<String, Object> headers = ImmutableMap.of("message-group-id", groupId.toString(), "message-deduplication-id", UUID.randomUUID().toString()); notificationMessagingTemplate.convertAndSend(topicName, payload, headers); } 通过SQS中的那些标头效果很好,但是在SNS中它不起作用,并且会出现错误: Caused by: com.amazonaws.services.sns.model.InvalidParameterException: Invalid parameter: The MessageGroupId parameter is required for FIFO topics (Service: AmazonSNS; Status Code: 400; Error Code: InvalidParameter; Request ID: 1aa83814-abc8-56e9-ae15-619723438fe9; Proxy: null) at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1819) ~[aws-java-sdk-core-1.11.933.jar:na] 我必须更改标题,否则还有另一种方式around? i我通过不使用春季的SDK找到了一种方法,因为SNS的FIFO是新的,春季还没有针对此问题实现任何解决方案,我找不到通过春季通过春季将参数传递到该主题的方法,以下是链接这有助于我解决:https://docs.aws.amazon.com/sns/latest/dg/fifo-topic-code-examples.html 这是我的方法的完成方式: private final String topicArn; private final AmazonSNS amazonSNS; private final ObjectMapper objectMapper; public void send(final T payload, final Object groupId) { try { amazonSNS.publish(new PublishRequest() .withTopicArn(topicArn) .withMessageDeduplicationId(UUID.randomUUID().toString()) .withMessage(objectMapper.writeValueAsString(payload)) .withMessageGroupId(groupId.toString())); } catch (final IOException e) { throw new RuntimeException(e); } } 如果您不想更新您的spring-cloud-aws,如下所述: https://github.com/spring-attic/spring-cloud-aws/issues/714,您可以执行以下操作: 创建处理程序以在发送消息之前拦截该消息 import com.amazonaws.Request; import com.amazonaws.handlers.RequestHandler2; import com.amazonaws.services.sns.model.PublishRequest; public class SnsFifoHandler extends RequestHandler2 { @Override public void beforeRequest(Request<?> request) { super.beforeRequest(request); if (request.getOriginalRequest() instanceof PublishRequest) { PublishRequest publishRequest = (PublishRequest) request.getOriginalRequest(); if (publishRequest.getTopicArn().contains("fifo")) { String messageGroupId = publishRequest.getMessageAttributes() .get("MessageGroupId") .getStringValue(); String deduplicationId = publishRequest.getMessageAttributes() .get("MessageDeduplicationId") .getStringValue(); request.addParameter("MessageGroupId", messageGroupId); request.addParameter("MessageDeduplicationId", deduplicationId); } } } } 将其放在弹簧豆 @Bean public SnsFifoHandler snsFifoHandler() { return new SnsFifoHandler(); } 用它来构建Amazonsnsasync bean实例 @Bean public AmazonSNSAsync amazonSNSAsync(SnsFifoHandler snsFifoHandler) { return AmazonSNSAsyncClientBuilder.standard().withRegion(region).withRequestHandlers(snsFifoHandler).build(); } 最终发送消息 import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.aws.messaging.core.NotificationMessagingTemplate; import org.springframework.stereotype.Service; @Service public class MessagingService { @Autowired private NotificationMessagingTemplate notificationMessagingTemplate; public void sendToFifoTopic(Object message, String topicName, String messageGroupId, String messageDeduplicationId) { notificationMessagingTemplate.convertAndSend( topicName, message, Map.of("MessageGroupId", messageGroupId, "MessageDeduplicationId", messageDeduplicationId)); } } 我解决了以下内容: SnsNotification<Event> notification = SnsNotification.builder(event) .groupId("theGroupId") .deduplicationId("theDeduplicationId") .build(); snsTemplate.sendNotification(snsTopicArn, notification);

回答 3 投票 0


sns发送肌肉command我有无效的参数:dataprotectionpolicy原因:无法解析数据保护策略

I在AWS上创建了一个“推送通知平台-Apple iOS(开发)” 我只是想从AWS SDK JS V3创建一个新的终点 const deviceid ='a0b1c2d3e4f5'//将是真正的

回答 1 投票 0

SNS FIFO topic 的消息是否严格按照顺序重试到 SQS FIFO Queue?

我们正在开发一种发布-订阅架构,我们希望使用 SNS 扇出到多个 SQS 队列。我们有严格的顺序要求,即每个客户的事件都应该按顺序进行。

回答 1 投票 0

AWS ElastiCache SNS 通知无效

我配置了 ElastiCache Redis 复制组以将通知发送到 SNS 主题。 SNS 主题使用自定义 KMS 密钥进行加密。 但我没有收到任何通知。检查 Redis

回答 1 投票 0

删除SNS平台应用,是否会删除所有注册的端点?

我正在尝试使用 terraform 配置 FCM SNS 平台应用程序。然后我使用 boto3 python 库为我的移动设备创建端点。我想如果我的平台应用程序是...

回答 2 投票 0

在 lambda 中获取 Cognito 验证码以使用本地提供商发送短信

我想使用我所在国家/地区的本地提供商以短信形式向用户手机发送验证码,而不使用 AWS SNS。 我在 CustomMessage 中有一个触发器,并且 lambda 函数工作正常。但我的

回答 3 投票 0

如何将实例 ID 传递给 Lambda 函数

我正在 AWS 中开发工作流程。场景是:每当我在日志组中收到可疑的日志条目(例如大量 403 错误)时。我希望实例与环境隔离。目前...

回答 1 投票 0

如何将电话号码列表订阅到 aws-sns 主题

我需要发送 200 条短信,在亚马逊文档中我找到了如何通过订阅一个主题但只能一条一条地做到这一点。 公共静态无效主(字符串[] args){ 亚马逊SNSC...

回答 2 投票 0

AWS SES 使用 Node.js 中的 SNS 通知转发退回邮件、投诉和/或递送

我真的很困惑如何设置 Amazon SES 电子邮件的状态;退回邮件、投诉和/或使用 Node.js 发送以通过 SNS 转发。我尝试遵循他们的文档 我首先...

回答 2 投票 0

将 AWS SNS 通知发送到动态电子邮件地址

我有一个 lambda 正在向其发送消息的 SNS 主题。特定消息包含此消息应从 SNS 发送到的电子邮件地址。我可以在...中创建电子邮件主题订阅者吗

回答 1 投票 0

Amazon SNS - aws-sdk-php

我正在使用适用于 PHP 的 AWS 开发工具包 - 版本 3。 当我发送一条 SMS 消息时,下面的代码运行良好,但属性 DefaultSenderID 除外,当我向移动设备发送 SMS 消息时,该属性不起作用...

回答 1 投票 0

SNS 到 Lambda 与 SNS 到 SQS 到 Lambda

我正在尝试了解我的工作流程中是否需要 SQS,如果有人可以帮助解释的话。在我的应用程序中,当采取操作时,它会将信息提交到 SNS 主题,该主题调用 Lambda 进行一些处理。 ...

回答 6 投票 0

使用 AWS Amplify iOS 接收消息以便正确触发 onNotification 事件的 APNS 消息结构是什么?

我从 @aws-amplify/pushnotification 设置 PushNotification.onNotification,如下所示: if (notification.foreground) { console.log('前台收到通知', notification); ...

回答 2 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.