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

関連記事

: Amazon WorkSpaces Web Accessを有効化する

仕事がら、Amazon WorkSpacesをディレクトリも含めて一時的にセット …

: AWS EC2 でインスタンスにIPアドレスを紐付ける

AWS EC2で作ったサーバは何もしなければ起動するたびにIPアドレスが変わって …

: AtomエディタでEC2のファイルを直接編集する

Webページを編集していてEC2のファイルをvimエディタでさわったりしています …

: S3リクエストメトリクスをプレフィックスを指定して有効化

検証でどのリクエストがどれぐらい発生しているのか、さっと知りたくなったので、特定 …

: 「CMC_Central 2024」に参加しました

個人サポーターとしてCMC_Central 2024に参加しました。オープニン …

: SendGridのイベントをAPI Gateway -> Lambda(Python) -> DynamoDBに格納する

SendGridのメールイベントログはコンソールで確認出来るのは直近7日分で一括 …

: Amazon Location Service入門ワークショップ-ルート計算

Amazon Location Service入門ワークショップのアプリで、ルー …

: 別アカウントのVPCからAWS PrivateLinkを使う

VPC エンドポイントサービス (AWS PrivateLink)を参考にしまし …

: DynamoDB IAMポリシーで特定属性だけを許可する

検証記録です。対象テーブル書籍のサンプルで作ったこちらです。所属バンドの楽 …

: Amazon S3オブエジェクトへのリクエストをCloudTrail, Athenaで識別

こちらCloudTrail を使用した Amazon S3 リクエストの識別に書 …

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