James Kirk Jimeux

Jimeux / sns_message.json

Created July 19, 2018 02:46

	{
	"Type": "Notification",
	"MessageId": "63a3f6b6-d533-4a47-aef9-fcf5cf758c76",
	"TopicArn": "arn:aws:sns:ap-northeast-1:xxx:xxx",
	"Subject" : "Test Subject",
	"Message": "Test Message",
	"Timestamp": "2018-07-7T05:12:16.901Z",
	"SignatureVersion" : "1",
	"Signature": "EXAMPLEnTrFPa37tnVO0FF9Iau3MGzjlJLRfySEoWz4uZHSj6ycK4ph71Zmdv0NtJ4dC/El9FOGp3VuvchpaTraNHWhhq/OsN1HVz20zxmF9b88R8GtqjfKB5woZZmz87HiM6CYDTo3l7LMwFT4VU7ELtyaBBafhPTg9O5CnKkg=",
	"SigningCertURL": "https://sns.ap-northeast-1.amazonaws.com/SimpleNotificationService-xxx.pem",

Jimeux / aws_imports.go

Created July 19, 2018 02:51

	import (
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/sqs"
	"github.com/aws/aws-sdk-go/service/sns"
	)

Jimeux / aws_session.go

Created July 19, 2018 02:51

	var (
	region = os.Getenv("AWS_DEFAULT_REGION")
	queueURL = os.Getenv("QUEUE_URL")
	topicARN = os.Getenv("TOPIC_ARN")
	)

	awsSession, err := session.NewSession(&aws.Config{Region: &region})

Jimeux / sns_publish.go

Created July 19, 2018 02:52

	snsClient := sns.New(awsSession)

	subject := "Test Subject"
	message := "Test Message"

	_, err := snsClient.Publish(&sns.PublishInput{
	Subject: &subject,
	Message: &message,
	TopicArn: &topicARN,
	})

Jimeux / sqs_receive.go

Last active July 19, 2018 03:02

	sqsClient := sqs.New(awsSession)

	result, err := sqsClient.ReceiveMessage(&sqs.ReceiveMessageInput{
	QueueUrl: &queueURL,
	AttributeNames: aws.StringSlice([]string{
	sqs.MessageSystemAttributeNameSentTimestamp,
	}),
	MaxNumberOfMessages: aws.Int64(1),
	MessageAttributeNames: aws.StringSlice([]string{
	sqs.QueueAttributeNameAll,

Jimeux / sns_message.go

Created July 19, 2018 02:53

	import "time"

	type SnsMessage struct {
	Type string
	MessageId string
	TopicArn string
	Subject string
	Message string
	Timestamp time.Time
	SignatureVersion int `json:",string"`

Jimeux / sns_unmarshal.go

Created July 19, 2018 02:54

	snsMessage, _ := ReceiveMessage()

	var message SnsMessage
	json.Unmarshal([]byte(*snsMessage.Body), &message)

	fmt.Println(message.Message) // "Test Message"

Jimeux / sqs_delete_message.go

Created July 19, 2018 02:54

	snsMessage, _ := ReceiveMessage()
	message, _ := ParseMessageJSON(snsMessage)

	_, err := sqsClient.DeleteMessage(&sqs.DeleteMessageInput{
	QueueUrl: &queueURL,
	ReceiptHandle: snsMessage.ReceiptHandle,
	})

	if err != nil {
	fmt.Errorf("メッセージを削除できませんでした：" + *snsMessage.ReceiptHandle)

Jimeux / e3_upload_client.go

Created November 26, 2018 09:56

Jimeux / e4_upload_server.go

Last active November 29, 2018 02:21