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

関連記事

: DS18B20センサー+Raspberry Piで取得した温度をAmazon Kinesis FirehoseからS3へ格納してAthenaでクエリーしたのをQuickSightで可視化する

JAWS DAYS 2017でやりますハンズオンの「[IoTハンズオン] Ras …

: Amazon S3バケットでMFA Deleteを有効にする

バージョニングが有効なバケットでバージョン削除でMFA Deleteを有効にして …

: [事前準備] JAWS-UG 関西IoT専門支部「マクニカkibo + AWS IoTハンズオン」

来る12/19(土)の JAWS-UG 関西IoT専門支部第一回勉強会「マクニカ …

: Kinesis Data AnalyticsをKinesis Data Streamsに接続してSQL検索する

Amazon Kinesis Data StreamsにTwitter検索データ …

: AWS Organizations EC2宣言型ポリシーを設定する

2024/12/1に発表されましたOrganizationsの宣言型ポリシーを設 …

: ちょっとしたCLI作業にEC2起動テンプレート

CLIでちょっとした作業したいだけのときに、Cloud9を使うまでもないなあと思 …

: T2.microからT3.nanoに変更(メモリエラーも対応)

このブログのEC2インスタンスをT2.micro 1インスタンスからT3.nan …

: AWS CloudFormationでAmazon DynamoDBテーブルを作ってアイテムを追加する

デモ用にDynamoDBテーブルを作って消して、ということをたまにするので、Cl …

: ユーザーガイドの方法でGithubからCodeCommitへリポジトリを移行する

GitリポジトリをAWS CodeCommitに移行するを参照しました。環境 …

: LINE BOT AWARDS 2017に応募しました

LINEの友達追加QRです。動作のご確認にどうぞ LINE BOT AWARD …

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