growing hard days.

Amazon SNSサブスクリプションフィルターを設定してPython(boto3)からPublish

2021/08/02 2021/08/02

上記のような構成でRocketChatを使うとき使わないときがあります。
都度都度Lambdaのトリガーをオフにするのも面倒ですし、メッセージがSQSまで行ってしまうのもコストも効率も無駄です。

ということでサブスクリプションフィルターを設定しました。

目次

サブスクリプションフィルターの設定

RocketChatに向かうキューのサブスクリプションにサブスクリプションフィルターを設定しました。

{
  "rocket_chat": [
    "valid"
  ]
}

1

2

3

4

5

6

{

"rocket_chat": [

"valid"

]

}

対象の値が1つでも配列にしないといけないようです。

Lambda(Python boto3)

sns.publish(
            TopicArn=snsTopicArn,
            Message=json.dumps(event),
            MessageAttributes={
                'rocket_chat': {
                    'DataType': 'String',
                    'StringValue': 'valid'
                }
            }
        )

1

2

3

4

5

6

7

8

9

10

11

sns.publish(

TopicArn=snsTopicArn,

Message=json.dumps(event),

MessageAttributes={

'rocket_chat': {

'DataType': 'String',

'StringValue': 'valid'

}

}

)

MessageAttributesにフィルターで設定した値をStringValueとして追加しました。
予定通りの送信と、StringValueが違う値のときは送信されないことを確認できました。

最後までお読みいただきましてありがとうございました！

「AWS認定資格試験テキスト＆問題集　AWS認定ソリューションアーキテクト - プロフェッショナル改訂第2版」という本を書きました。

「AWS認定資格試験テキスト AWS認定クラウドプラクティショナー改訂第3版」という本を書きました。

「ポケットスタディ AWS認定デベロッパーアソシエイト［DVA-C02対応］」という本を書きました。

「要点整理から攻略するAWS認定ソリューションアーキテクト-アソシエイト」という本を書きました。

「AWSではじめるLinux入門ガイド」という本を書きました。

開発ベンダー5年、ユーザ企業システム部門通算9年、ITインストラクター5年目でプロトタイプビルダーもやりだしたSoftware Engineerです。
質問はコメントかSNSなどからお気軽にどうぞ。
出来る限りなるべく答えます。

このブログの内容/発言の一切は個人の見解であり、所属する組織とは関係ありません。
このブログは経験したことなどの共有を目的としており、手順や結果などを保証するものではありません。
ご参考にされる際は、読者様自身のご判断にてご対応をお願いいたします。

また、勉強会やイベントのレポートは自分が気になったことをメモしたり、聞いて思ったことを書いていますので、登壇者の意見や発表内容ではありません。

- AWS AWS, python, sns

Tweet

関連記事

: CodeGuru ProfilerでLambda関数(Python 3.9)のパフォーマンスを確認した

CodeGuru ProfilerでPython 3.9のLambda関数の推奨 …

: 東京リージョンの1つのAZ(apne1-az2)でt3.nanoスポットインスタンスが拒否されちゃいました

拒否されちゃいましたちょっとした検証をしようとしてて、t3.nanoのスポット …

: AWSクイックスタートのActive Directory Domain Services on AWS

オンプレミスに見立てたActive Directory環境がほしかったので、AW …

: Route53でドメインを新規取得してDNSレコードを設定する

Elastic IPをAWSで発行しているのですから、DNSの設定も同じようにマ …

: 「機械学習モデルをトレーニングする」チュートリアル

Amazon SageMaker Clarifyのデモを記録しておきたいので「機 …

: S3バケットのデフォルト暗号化はデフォルトだったことを確認しました

S3バケットのデフォルト暗号化は名前のとおりだとデフォルトなので、暗号化を指定し …

: Developers Summit 2018 「AWSのフルマネージドな環境でCI/CDをやってみよう！AWS Cloud9からAWS Fargateへの継続的デプロイをご紹介」を聞きました

※写真は展示のAmazon Echoです。以下は、思ったことや気になったことを …

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

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

: VPCピア接続した先のVPCインターフェイスエンドポイントを使用する

VPC1とVPC2でピア接続しています。 VPC2にはKMSのインターフェイスエ …

: EC2 Dedicated Hosts(専有ホスト)を起動

クォータ引き上げ新規で作成したアカウントではDedicated Hostsがソ …

PREV: 執筆などで使えるグローバルIPアドレス
NEXT: Amazon SNSサブスクリプションフィルターで優先度別のSQSキューにサブスクライブする