Amazon SNSサブスクリプションフィルターで優先度別のSQSキューにサブスクライブする
2021/08/03
EC2のコンシューマーアプリケーションは優先度の高いキューのメッセージを先に処理して、優先度の高いキューにメッセージがないときに優先度の低いキューのメッセージを処理したい、そんな想定ケースでSNSサブスクリプションフィルターを使ってみました。
SNSのサブスクリプションは2つのSQSキュー(HighPriority, LowPriority)です。
HighPriorityのサブスクリプションフィルター
1 2 |
{"priority": [{"numeric": [">=", 7]}]} |
LowPriorityのサブスクリプションフィルター
1 2 |
{"priority": [{"numeric": ["<", 7]}]} |
CloudShellにPythonファイルを作成して、実行テストしました。
sns_filter.py
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) |
高い優先度メッセージの送信
1 2 |
$ python3 sns_filter.py 7 |
HighPriorityキューにメッセージが送信されました。
低い優先度メッセージの送信
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などからお気軽にどうぞ。
出来る限りなるべく答えます。
このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。
また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。
ad
ad
関連記事
-
-
AWS Client VPNのクライアント接続ハンドラを試してみました
AWS Client VPNを設定しましたで証明書とかせっかく作ったので、いろい …
-
-
Amazon Elasticsearch ServiceにMySQLのデータを投入してkibanaで可視化してみる
MySQLのデータの可視化にAmazon Elasticsearch Servi …
-
-
JAWS DAYS 2018 「Cost-Driven AWS クラウドアーキテクチャデザインとコスト最適化方法 – Cost-Driven AWS Cloud Architecture Design : The Lean Startup on AWS」を聞きました
以下は、思ったことや気になったことをメモしていますので、必ずしも登壇者の発表内容 …
-
-
Pandocサーバーのコンテナイメージを作成する
マークダウンからEPUBへの変換をAWS Batchで行いたく、ECRにアップロ …
-
-
EC2スポットインスタンスの中断通知を受ける
オートスケーリンググループでEC2インスタンスをスポットインスタンスで使用してい …
-
-
AWS Toolkit for Eclipseで「Error Message: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region.」
AWS Toolkit for Eclipseをセットアップ(2021年版)の環 …
-
-
AWS Transfer Family S3向けのSFTP対応サーバー
S3バケットは作成済です。 IAMロールの作成 [crayon-67f3c68a …
-
-
Cloud9でAWS CDK環境
最初ローカルに作ろうと思ったのですが、環境依存がというか、Macbookの環境で …
-
-
RDS ProxyをAurora MySQLで
Lambda関数をたくさん同時実行してMySQLにアクセスしても大丈夫なようにR …
-
-
CloudWatch LogsメトリクスフィルタでNginxのaccess_logから転送バイト数をモニタリングする
ユーザーガイドのApache ログからのフィールドの抽出を見てて、これ、Ngin …