vb.net 使用 AWS .NET SDK 的 SNS 订阅确认示例

Example SNS subscription confirmation using AWS .NET SDK

提问by Scott Anderson

I am trying to figure out how to use the AWS .NET SDK to confirm a subscription to a SNS Topic.

我想弄清楚如何使用 AWS .NET SDK 来确认对 SNS 主题的订阅。

The subscription is via HTTP

订阅是通过 HTTP

The endpoint will be in a .net mvc website.

端点将位于 .net mvc 网站中。

I can't find any .net examples anywhere?

我在任何地方都找不到任何 .net 示例？

A working example would be fantastic.

一个工作示例会很棒。

I'm trying something like this

我正在尝试这样的事情

 Dim snsclient As New Amazon.SimpleNotificationService.AmazonSimpleNotificationServiceClient(ConfigurationSettings.AppSettings("AWSAccessKey"), ConfigurationSettings.AppSettings("AWSSecretKey"))

    Dim TopicArn As String = "arn:aws:sns:us-east-1:991924819628:post-delivery"


    If Request.Headers("x-amz-sns-message-type") = "SubscriptionConfirmation" Then

        Request.InputStream.Seek(0, 0)
        Dim reader As New System.IO.StreamReader(Request.InputStream)
        Dim inputString As String = reader.ReadToEnd()

        Dim jsSerializer As New System.Web.Script.Serialization.JavaScriptSerializer
        Dim message As Dictionary(Of String, String) = jsSerializer.Deserialize(Of Dictionary(Of String, String))(inputString)

        snsclient.ConfirmSubscription(New Amazon.SimpleNotificationService.Model.ConfirmSubscriptionRequest With {.AuthenticateOnUnsubscribe = False, .Token = message("Token"), .TopicArn = TopicArn})


   End If

采纳答案by Scott Anderson

I ended up getting it working using the code shown. I was having trouble capturing the exception on the development server which turned out was telling me the server's time didn't match the timestamp in the SNS message.

我最终使用显示的代码让它工作。我在开发服务器上捕获异常时遇到问题，结果告诉我服务器的时间与 SNS 消息中的时间戳不匹配。

Once the server's time was fixed up (an Amazon server BTW), the confirmation worked.

一旦服务器的时间被修复（亚马逊服务器 BTW），确认工作。

回答by cmilam

Here is a working example using MVC WebApi 2 and the latest AWS .NET SDK.

这是一个使用 MVC WebApi 2 和最新的 AWS .NET SDK 的工作示例。

var jsonData = Request.Content.ReadAsStringAsync().Result;
var snsMessage = Amazon.SimpleNotificationService.Util.Message.ParseMessage(jsonData);

//verify the signaure using AWS method
if(!snsMessage.IsMessageSignatureValid())
    throw new Exception("Invalid signature");

if(snsMessage.Type == Amazon.SimpleNotificationService.Util.Message.MESSAGE_TYPE_SUBSCRIPTION_CONFIRMATION)
{
    var subscribeUrl = snsMessage.SubscribeURL;
    var webClient = new WebClient();
    webClient.DownloadString(subscribeUrl);
    return "Successfully subscribed to: " + subscribeUrl;
}

回答by sobelito

Building on @Craig's answer above (which helped me greatly), the below is an ASP.NET MVC WebAPI controller for consuming and auto-subscribing to SNS topics. #WebHooksFTW

基于上面@Craig 的回答（这对我帮助很大），下面是一个 ASP.NET MVC WebAPI 控制器，用于使用和自动订阅 SNS 主题。#WebHooksFTW

using RestSharp;
using System;
using System.Net;
using System.Net.Http;
using System.Reflection;
using System.Web.Http;
using System.Web.Http.Description;

namespace sb.web.Controllers.api {
  [System.Web.Mvc.HandleError]
  [AllowAnonymous]
  [ApiExplorerSettings(IgnoreApi = true)]
  public class SnsController : ApiController {
    private static string className = MethodBase.GetCurrentMethod().DeclaringType.Name;

    [HttpPost]
    public HttpResponseMessage Post(string id = "") {
      try {
        var jsonData = Request.Content.ReadAsStringAsync().Result;
        var sm = Amazon.SimpleNotificationService.Util.Message.ParseMessage(jsonData);
        //LogIt.D(jsonData);
        //LogIt.D(sm);

        if (!string.IsNullOrEmpty(sm.SubscribeURL)) {
          var uri = new Uri(sm.SubscribeURL);
          var baseUrl = uri.GetLeftPart(System.UriPartial.Authority);
          var resource = sm.SubscribeURL.Replace(baseUrl, "");
          var response = new RestClient {
            BaseUrl = new Uri(baseUrl),
          }.Execute(new RestRequest {
            Resource = resource,
            Method = Method.GET,
            RequestFormat = RestSharp.DataFormat.Xml
          });
          if (response.StatusCode != System.Net.HttpStatusCode.OK) {
            //LogIt.W(response.StatusCode);
          } else {
            //LogIt.I(response.Content);
          }
        }

        //read for topic: sm.TopicArn
        //read for data: dynamic json = JObject.Parse(sm.MessageText);
        //extract value: var s3OrigUrlSnippet = json.input.key.Value as string;

        //do stuff
        return Request.CreateResponse(HttpStatusCode.OK, new { });
      } catch (Exception ex) {
        //LogIt.E(ex);
        return Request.CreateResponse(HttpStatusCode.InternalServerError, new { status = "unexpected error" });
      }
    }
  }
}

回答by Dave R

I don't know how recently this has changed, but I've found that AWS SNS now provides a very simply method for subscribing that doesn't involve extracting urls or building requests using RESTSharp.....Here's the simplified WebApi POST method:

我不知道最近情况如何改变，但我发现 AWS SNS 现在提供了一种非常简单的订阅方法，不涉及使用 RESTSharp 提取 url 或构建请求......这是简化的 WebApi POST 方法：

    [HttpPost]
    public HttpResponseMessage Post(string id = "")
    {
        try
        {
            var jsonData = Request.Content.ReadAsStringAsync().Result;
            var sm = Amazon.SimpleNotificationService.Util.Message.ParseMessage(jsonData);

            if (sm.IsSubscriptionType)
            {
                sm.SubscribeToTopic(); // CONFIRM THE SUBSCRIPTION
            }
            if (sm.IsNotificationType) // PROCESS NOTIFICATIONS
            {
                //read for topic: sm.TopicArn
                //read for data: dynamic json = JObject.Parse(sm.MessageText);
                //extract value: var s3OrigUrlSnippet = json.input.key.Value as string;
            }

            //do stuff
            return Request.CreateResponse(HttpStatusCode.OK, new { });
        }
        catch (Exception ex)
        {
            //LogIt.E(ex);
            return Request.CreateResponse(HttpStatusCode.InternalServerError, new { status = "unexpected error" });
        }
    }

回答by Vladimir Sozinov

As @cmilam answered, you should install aws sdk (it's name "AWSSDK.SimpleNotificationService", https://github.com/aws/aws-sdk-net/). Dependencies were resolved after install this package.

正如@cmilam 回答的那样，您应该安装 aws sdk（它的名称为“AWSSDK.SimpleNotificationService”，https://github.com/aws/aws-sdk-net/）。安装此包后解决了依赖关系。

回答by EFeit

The following example helped me work with SNS. It goes through all the steps to work with Topics. The subscribe request in this case is an email address, however that can be changed to HTTP.

以下示例帮助我使用 SNS。它经历了处理主题的所有步骤。在这种情况下，订阅请求是一个电子邮件地址，但可以更改为 HTTP。

Pavel's SNS Example
Documentation

Pavel 的 SNS 示例
文档