sns-message-sender

sns-message-sender

Amazon SNSにメッセージを発行するサンプルプログラム

簡単な説明

Webアプリ上でDBに登録、更新、削除した時にAmazon SNSにメッセージを発行します。 Amazon SNSが指定された条件のAmazonSQSにメッセージを送ります。

必要要件

実行環境

• go 1.15.6 windows/amd64
• MariaDB 10.5.8

Amazon SNS, SQSを使用するためアカウント登録が必要です。

使い方

Webアプリ上で登録、更新、削除を行ってください。

インストール

データベース

MariaDBをインストールしてDBを作成してください。 （テーブルは初回起動時に自動で作成されます。）

database/database.go にDBの設定を入力してください。

• USER ： DBのユーザ名 例）"test_user"
• PASS ： 上記ユーザのパスワード 例）"test_pass"
• HOST ： DBのホスト名もしくはIP 例）"localhost"
• PORT ： DBのポート番号 例）"3306"
• DBNAME ： データベース名 例）"exampledb"

Amazon SNS トピック作成、設定

AWSにログインし、SNSサービスのページに遷移します。 ⇒開発時にはリージョンはアジアパシフィック（東京） ap-northeast-1を選択しました。

トピックを作成します。 ⇒開発時には名前のみ入力しそれ以外はデフォルトで作成しました。

作成したトピックの詳細にあるARNを控えてください。

message/message.go にSNSの設定を入力してください。

• AWS_REGION ： リージョン 例）"ap-northeast-1"
• QUEUE_URL ： 上記で取得したARN 例）"arn:aws:sns:ap-northeast-1:123456789012:SampleTopic"
• DO_NOTHING ： 通常はfalse 例）false 　⇒メッセージを送信したくない場合はtrueにしてください。

Amazon SQS

SQSサービスのページに遷移します。 ⇒開発時にはリージョンはアジアパシフィック（東京） ap-northeast-1を選択しました。

キューを作成します。 ⇒開発時には名前のみ入力しそれ以外はデフォルトで作成しました。 ⇒SNSでフィルタリングされるのを確認するため2つ作成してください。

キューの詳細からAmazon SNS トピックにサブスクライブをクリックし、 先ほど作成したSNSのトピックを選択して、保存してください。

Amazon SNS フィルタ設定

SNSのトピック詳細のページに遷移します。 サブスクリプションに上記で登録したSQSが表示されていることを確認し、 IDのリンクからサブスクリプションの詳細画面に遷移します。

サブスクリプションフィルターポリシーに以下のように登録してください。

{
  "Key": [
    "sample1"
  ]
}

上記のsample1がフィルタの条件になります。 SQS毎に任意に変更してください。

　注意：AWSの画面上反映されたように見えてもフィルタの設定に時間がかかることがあるようです。

AWS認証情報設定

AWSのアクセスキー ID と シークレットアクセスキー を取得します。 （AWSユーザ登録時に届くメールなど）

ここではWindwosのコマンドプロンプトから実行する時に一時的に環境変数に登録するコマンドを載せます。 詳細はAWSのユーザガイドを見てください。

https://docs.aws.amazon.com/ja_jp/cli/latest/userguide/cli-configure-envvars.html

コマンドプロンプトで以下のコマンドを実行してください。 この書き方の場合、コマンドプロンプトを起動するたびに実行する必要があります。

set AWS_ACCESS_KEY_ID=XXXXXXXXXXX
set AWS_SECRET_ACCESS_KEY=XXXXXXXXXXXXX

go言語のライブラリ

以下のコマンドで必要なライブラリをインストールしてください。

go get github.com/go-sql-driver/mysql
go get github.com/jinzhu/gorm
go get github.com/gin-gonic/gin
go get github.com/aws/aws-sdk-go

起動と実行

publisherディレクトリに移動し、以下のコマンドで起動します。

go run main.go

localhostの場合、ブラウザで以下のURLにアクセスしてください。

http://localhost/

ポートを変更したい場合、main.goのPORTを変更してください。

各画面のAmazon SNSフィルタにAmazon SNS フィルタ設定で設定した フィルタの条件と同じ文字列を入力した場合、対象のSQSにメッセージが送られます。

その他

• 実行したあと、Amazon SQS上でメッセージを確認したい場合、キューの詳細画面から「メッセージを送受信」をクリック⇒「メッセージをポーリング」で確認できます。