본문으로 바로가기


ASP.NET MVC 에서 AWS SES 의 BOUNCE 응답값 HEADERS 안의 BODY 파싱하기

POST / HTTP/1.1

x-amz-sns-message-type: Notification x-amz-sns-message-id: 22b80b92-fdea-4c2c-8f9d-bdfb0c7bf324 x-amz-sns-topic-arn: arn:aws:sns:us-west-2:123456789012:MyTopic x-amz-sns-subscription-arn: arn:aws:sns:us-west-2:123456789012:MyTopic:c9135db0-26c4-47ec-8998-413945fb5a96 Content-Length: 773 Content-Type: text/plain; charset=UTF-8 Host: example.com Connection: Keep-Alive User-Agent: Amazon Simple Notification Service Agent { "Type" : "Notification", "MessageId" : "22b80b92-fdea-4c2c-8f9d-bdfb0c7bf324", "TopicArn" : "arn:aws:sns:us-west-2:123456789012:MyTopic", "Subject" : "My First Message", "Message" : "Hello world!", "Timestamp" : "2012-05-02T00:54:06.655Z", "SignatureVersion" : "1", "Signature" : "EXAMPLEw6JRNwm1LFQL4ICB0bnXrdB8ClRMTQFGBqwLpGbM78tJ4etTwC5zU7O3tS6tGpey3ejedNdOJ+1fkIp9F2/LmNVKb5aFlYq+9rk9ZiPph5YlLmWsDcyC5T+Sy9/umic5S0UQc2PEtgdpVBahwNOdMW4JPwk0kAJJztnc=", "SigningCertURL" : "https://sns.us-west-2.amazonaws.com/SimpleNotificationService-f3ecfb7224c7233fe7bb5f59f96de52f.pem", "UnsubscribeURL" : "https://sns.us-west-2.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:us-west-2:123456789012:MyTopic:c9135db0-26c4-47ec-8998-413945fb5a96" }


MODEL 을 위의 JSON 형태로 구성합니다.

public class BouncedEntity
{
public string Type { get; set; }
public string MessageId { get; set; }
public string Token { get; set; }
public string TopicArn { get; set; }
public string Message { get; set; }
public string SubscribeURL { get; set; }
public DateTime Timestamp { get; set; }
public string SignatureVersion { get; set; }
public string Signature { get; set; }
public string SigningCertURL { get; set; }
}


이제 CONTROLLER 에서 HEADER 값을 가져오는 구문이며, BODY 의 JSON 은 MODEL 에 담습니다.

담을때 JsonConvert.DeserializeObject<BouncedEntity>(jsonData); 구문으로 간단히 담을 수 있습니다. 다중 값이면 제네릭 LIST<> 를 기술하여 사용하시면 됩니다.

var xmessageType = Request.Headers["x-amz-sns-message-type"];
var xmessageid = Request.Headers["x-amz-sns-message-id"];
var xtopicarn = Request.Headers["x-amz-sns-topic-arn"];
var xsubscriptionarn = Request.Headers["x-amz-sns-subscription-arn"];

Request.InputStream.Seek(0, SeekOrigin.Begin);
string jsonData = new StreamReader(Request.InputStream).ReadToEnd();

var modelBounced = JsonConvert.DeserializeObject<BouncedEntity>(jsonData);



전체 소스


using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApp1
{
class Program
{
static void Main(string[] args)
{
using (StreamReader r = new StreamReader(@"D:\SampleSource\ConsoleApp1\ConsoleApp1\notice.json"))
{
string jsonString = r.ReadToEnd();
var modelMain = JsonConvert.DeserializeObject<RootMain>(jsonString);

Console.WriteLine(modelMain.Type);
Console.WriteLine(modelMain.MessageId);
Console.WriteLine(modelMain.Token);
Console.WriteLine(modelMain.TopicArn);
//Console.WriteLine(modelMain.Message);
Console.WriteLine(modelMain.SubscribeURL);
Console.WriteLine(modelMain.SignatureVersion);
Console.WriteLine(modelMain.Signature);
Console.WriteLine(modelMain.SigningCertURL);
Console.WriteLine(modelMain.UnsubscribeURL);


if (modelMain.Type == "Notification")
{
var modelBounced = JsonConvert.DeserializeObject<RootMessageJson>(modelMain.Message);

Console.WriteLine(modelBounced.notificationType); //Bounce

if (modelBounced.bounce.bouncedRecipients.Count() > 0)
{
Console.WriteLine(modelBounced.bounce.bouncedRecipients[0].action); //failed
Console.WriteLine(modelBounced.bounce.bouncedRecipients[0].diagnosticCode); //smtp; 505 this account is unknown user~
Console.WriteLine(modelBounced.bounce.bouncedRecipients[0].emailAddress); //xxxxx@univ.me
Console.WriteLine(modelBounced.bounce.bouncedRecipients[0].status); //5.3.0
}

Console.WriteLine(modelBounced.mail.messageId);
Console.WriteLine(modelBounced.mail.sendingAccountId);
Console.WriteLine(modelBounced.mail.source);
Console.WriteLine(modelBounced.mail.sourceArn);
Console.WriteLine(modelBounced.mail.sourceIp);
Console.WriteLine(modelBounced.mail.timestamp);

Console.WriteLine(modelBounced.mail.commonHeaders.subject);
}
}


Console.ReadKey();
}



}

public class RootMain
{
public string Type { get; set; } = "";
public string MessageId { get; set; } = "";
public string Token { get; set; } = "";
public string TopicArn { get; set; } = "";
public string Message { get; set; } = "";
public string SubscribeURL { get; set; } = "";
public DateTime Timestamp { get; set; }
public string SignatureVersion { get; set; } = "";
public string Signature { get; set; } = "";
public string SigningCertURL { get; set; } = "";
public string UnsubscribeURL { get; set; } = "";

}

/// <summary>
/// TYPE 이 Notification 경우, Message 의 json 값 object 할당하기
/// </summary>
public class RootMessageJson
{
public string notificationType { get; set; } = "";
public Bounced bounce { get; set; }
public Mail mail { get; set; }
}

public class BouncedRecipient
{
public string emailAddress { get; set; } = "";
public string action { get; set; } = "";
public string status { get; set; } = "";
public string diagnosticCode { get; set; } = "";
}

public class Bounced
{
public string bounceType { get; set; } = "";
public string bounceSubType { get; set; } = "";
public List<BouncedRecipient> bouncedRecipients { get; set; }
public DateTime timestamp { get; set; }
public string feedbackId { get; set; } = "";
public string remoteMtaIp { get; set; } = "";
public string reportingMTA { get; set; } = "";
}

public class Header
{
public string name { get; set; } = "";
public string value { get; set; } = "";
}

public class CommonHeaders
{
public List<string> from { get; set; }
public List<string> to { get; set; }
public string subject { get; set; } = "";
}

public class Mail
{
public DateTime timestamp { get; set; }
public string source { get; set; } = "";
public string sourceArn { get; set; } = "";
public string sourceIp { get; set; } = "";
public string sendingAccountId { get; set; } = "";
public string messageId { get; set; } = "";
public List<string> destination { get; set; }
public bool headersTruncated { get; set; }
public List<Header> headers { get; set; }
public CommonHeaders commonHeaders { get; set; }
}

}





댓글을 달아 주세요