subscriber

subscriber

Amazon SQSからメッセージを取得するサンプルプログラム

簡単な説明

Amazon SQSからメッセージを取得し、DBに反映します。 また、受信したメッセージを削除します。

必要要件

実行環境

• go 1.15.6 windows/amd64
• MariaDB 10.5.8

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

使い方

Webアプリ上のメッセージ取得ボタンをクリックしてください。

https://github.com/s-kikkawa/publisher を使用してAmazon SQSに登録したメッセージを想定しています。
メッセージの形式が違うとDBに登録できません。

インストール

データベース

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

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

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

Amazon SQS

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

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

キューの一覧にある作成したキューのリンクをクリックし、詳細情報からURLをコピーします。

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

• AWS_REGION ： リージョン 例）"ap-northeast-1"
• QUEUE_URL ： 上記で取得したURL 例）"https://sqs.ap-northeast-1.amazonaws.com/123456789012/TestQueue"
• DO_NOTHING ： 通常はfalse 例）false
  　⇒メッセージを受信したくない場合はtrueにしてください。

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:8080/

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

その他

• 同じメッセージを複数取得した場合、順番が違う場合などは考慮していません。 （FIFOキューなどは試していません。）