growing hard days.

Amazon SNSサブスクリプションフィルターで優先度別のSQSキューにサブスクライブする

2021/08/03 2021/08/03

EC2のコンシューマーアプリケーションは優先度の高いキューのメッセージを先に処理して、優先度の高いキューにメッセージがないときに優先度の低いキューのメッセージを処理したい、そんな想定ケースでSNSサブスクリプションフィルターを使ってみました。

SNSのサブスクリプションは2つのSQSキュー(HighPriority, LowPriority)です。

HighPriorityのサブスクリプションフィルター

{"priority": [{"numeric": [">=", 7]}]}

1 2	{"priority": [{"numeric": [">=", 7]}]}

LowPriorityのサブスクリプションフィルター

{"priority": [{"numeric": ["<", 7]}]}

1 2	{"priority": [{"numeric": ["<", 7]}]}

CloudShellにPythonファイルを作成して、実行テストしました。

sns_filter.py

import sys
import boto3

args = sys.argv
priority = args[1]

sns = boto3.resource('sns')
topic = sns.Topic('arn:aws:sns:us-east-1:123456789012:FilterTest')

response = topic.publish(
        Message='Priority:{}'.format(priority),
        MessageAttributes={
            'priority': {
                'DataType': 'Number',
                'StringValue': priority
            }
        }
)

print(response)

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

import sys

import boto3

args = sys.argv

priority = args[1]

sns = boto3.resource('sns')

topic = sns.Topic('arn:aws:sns:us-east-1:123456789012:FilterTest')

response = topic.publish(

Message='Priority:{}'.format(priority),

MessageAttributes={

'priority': {

'DataType': 'Number',

'StringValue': priority

}

}

)

print(response)

高い優先度メッセージの送信

$ python3 sns_filter.py 7

1 2	$ python3 sns_filter.py 7

HighPriorityキューにメッセージが送信されました。

低い優先度メッセージの送信

$ python3 sns_filter.py 1

1 2	$ python3 sns_filter.py 1

LowPriorityキューにメッセージが送信されました。

最後までお読みいただきましてありがとうございました！

「AWS認定資格試験テキスト＆問題集　AWS認定ソリューションアーキテクト - プロフェッショナル改訂第2版」という本を書きました。

「AWS認定資格試験テキスト AWS認定クラウドプラクティショナー改訂第3版」という本を書きました。

「ポケットスタディ AWS認定デベロッパーアソシエイト［DVA-C02対応］」という本を書きました。

「要点整理から攻略するAWS認定ソリューションアーキテクト-アソシエイト」という本を書きました。

「AWSではじめるLinux入門ガイド」という本を書きました。

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS AWS, python, sns, sqs

Tweet

関連記事

: Windows EC2インスタンスでEBSとインスタンスストアを使用する

Amazon EBS基本のデモ(「AWS認定試験テキスト AWS認定クラウドプ …

: AWS Summit Tokyo 2017 Day3 開場~基調講演~Dev Day Night

AWS Summit Tokyo 2017 参加2日目のDay3です。基調講演 …

: AWS KMSのキーポリシーとアイデンティティベースポリシー

AWS KMSのCMKを作成する際に、管理者とキーユーザーを選択することで、以下 …

: AWS Lambda(Python3.7)でPandocを実行する際にCSSもLayerから読み込む

Pandocで必要そうなオプションを確認しておく先日の「AWS Lambda( …

: EFSをEC2(Amazon Linux 2)からマウントする

Amazon Elastic File Systemが東京リージョンに来たことも …

: AWS EC2 Amazon Linux にEC-CUBE3をnginx+MySql環境へインストール(手順検証中)

EC2インスタンスを作成する少し古い記事で恐縮ですが試したい事があるのでAWS …

: S3インベントリ設定でインベントリファイルの作成を設定

インベントリレポートファイルはオブジェクトの一覧情報です。日次、週次で定期作成 …

: Amazon CloudWatch クロスリージョンクロスアカウントダッシュボードを作成

本ブログのCloudFrontとWAFのアカウントと、EC2、RDS、S3などオ …

: RDSのスナップショットをS3へエクスポートが日本語マネジメントコンソールでもできるようになってました

RDSスナップショットをS3にエクスポートする新機能を試そうかと思ったのときは、 …

: ヤマムギvol.23 Amazon RDS for MySQLとAmazon Aurora Serverlessの起動のデモをしました

ゴールデンウィーク毎朝デモ勉強会は終わったのですが、土曜日にやれるときがあれば、 …

PREV: Amazon SNSサブスクリプションフィルターを設定してPython(boto3)からPublish
NEXT: Amazon EC2 Auto Scalingのライフサイクルフック