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

関連記事

: JAWS-UG関西IoT専門支部 ✕ SORACOM UG 関西「Wio LTE + 絶対圧センサーで遊ぼう！」ワークショップにいってきた

JAWS-UG関西IoT専門支部 ✕ SORACOM UG 関西「Wio LTE …

: ads.txtをS3に配置してCloudFrontで設定する

ads.txtのダウンロード ads.txt設置してねってメールが来てました。 …

: AWS複数アカウントのリソースをLambda(Python)から一括操作したくて

AWSの複数アカウント(30ちょい)のリソースをまとめて自動処理したくて。とり …

: AWS GlueでAurora JDBC接続でS3へのジョブを実行

Aurora Serverless v1のMySQLタイプデータベースからS3へ …

: cfn-initでEC2インスタンスにPHPをインストールしWebサーバーを起動する

AWS CloudFormation による Amazon EC2 へのアプリケ …

: Amazon VPCでIPv6を使用する

VPCのIPv6を設定してみました。設定 [Amazon 提供の IPv6 C …

: CodeBuildで執筆原稿データをまとめた

今書いている原稿に対して編集者さんから、「できればで構わないのですが、章ごとにマ …

: Amazon Route 53 Resolverを設定確認

Route 53 Resolverを設定しました。東京リージョンのVPCをオン …

: Amazon Connectで電話を転送する

かかってきた電話を転送するようにしました。問い合わせフローで[終了/転送]から …

: Amazon LinuxにAlfresco Community Editionをインストールする

ダウンロード準備 Alfresco公式サイトで、「エンタープライズコンテンツ管理 …

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