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

関連記事

: AWS OrganizatonsのRCP(リソースコントロールポリシー)を設定しました

2024/11月に発表されましたリソースコントロールポリシーを管理している組織に …

: CodeCommitリポジトリの復号化のCloudTrailログ確認

ユーザーガイドAWS Key Management Service と AWS …

: JAWS FESTA 2019 Sapporo 参加&当日スタッフ&企業サポーターで！

2019年のJAWS FESTA は札幌です！今回もありがたいことに、所属して …

: 特定AWSアカウント特定リージョンのCloudFormationスタックを削除するLambda(Python)

やりたいこと特定アカウント内特定リージョン内のCloudFormationスタ …

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

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

: CloudFrontからのバーチャルホストなサイトのテストってどうしてます？

このブログの構成です。 AWSで構築しています。 4つのサイトを1つのEC2で配 …

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

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

: API Gatewayで顧客レベルの使用量プランを設定する

API GatewayのAPIキーを使って使用量プランでのスロットリングも設定し …

: Amazon EC2 インスタンスメタデータサービス(IMDS) v2のみにしました

今さらながらですが、EC2 インスタンスメタデータサービス(IMDS) v2を確 …

: Amazon BedrockがGAしたので触りました(boto3からも)

Amazon Bedrock Is Now Generally Availabl …

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

NEW POST

: Amazon Q Developer for CLIをmacOSにインストールしました

2025/3/26のAWS Expert Online for JAWSの「Am …

Google ColabでOpenAIを使おうとしてTypeError: Client.init() got an unexpected keyword argument ‘proxies’エラー

import os
from google.colab import userdata
os.environ['OPENAI_API_KEY'] = userdata.get("OPENAI_API_KEY")
from openai import OpenAI
client = OpenAI()

1

2

3

4

5

6

import os

from google.colab import userdata

os.environ['OPENAI_API_KEY'] = userdata.get("OPENAI_API_KEY")

from openai import OpenAI

client = OpenAI()

とある書籍を参 …

: RocketChatの匿名登録時のtoo many requestsエラー対応

匿名ユーザー登録時のtoo many requestsエラー RocketCha …

: Amazon VPCのAmazonProvidedDNSとほかメモ

VPCユーザーガイドのAmazon DNS について理解するの記載内容について実 …

: Amazon SageMakerプロジェクトを使用してMLパイプラインを構築

SageMakerプロジェクトの作成 SageMaker Studioの左ナビゲ …

アーカイブ
アーカイブ