「Basic Ingest」をうまく使ってAWS IoT Coreのコストを削減しよう

概要

本エントリーでは、「AWS IoT」のコスト削減に寄与してくれるであろう「Basic Ingest」についてまとめます。
シンプルで導入しやすい機能なので、コスト削減を検討したい方は是非ご検討いただきたい機能です。

Reducing messaging costs with basic ingest

目次

• 1.Basic Ingestについて
• 2.やり方
• 3.やってみた
• 4.まとめ

1.Basic Ingestについて

AWSIoTを利用するにあたって、デバイスからAWSに送信したメッセージに基づいてなんらかのアクション（ex. lambda関数を実行）を実行したいケースは多いと思います。
そのためには、実行したい「ルールアクション」とそのトリガーとなる「ルール」を　「ルールエンジン」に設定する必要があります。
　「ルールエンジン」は　「メッセージブローカー」 を介して「デバイスゲートウェイ（デバイス）」からのメッセージを受け取ることで、「ルールアクション」を実行することができます。

「Basic Ingest」機能を利用すると、「メッセージブローカー」を介さず直接「ルールエンジン」にメッセージを送信できるため、メッセージングコストが削減できます。
（ルールエンジンやアクションのコストは変わらず発生する点に注意してください）

参照: AWS IoT Core 料金

注意点として、メッセージが「メッセージブローカーをバイパスする」ため「他のデバイスが対象のトピックをサブスクライブして、なんらかの処理を実行する」といったケースでは「Basic Ingest」は採用できません。
「Basic Ingest」は「デバイスからAWSにメッセージを送信してルールアクションを実行したいだけ」のような場合に採用しましょう。

また、そもそもメッセージングコストが小さいなら、無理して「Basic Ingest」を導入するメリットは小さいです。
例えば、以下は東京リージョン（2021年7月18日時点）での料金ですが、「毎月100万件のメッセージングしかしていない」場合はそもそもメッセージングコストに1.2USDしかかかっていないので、このコストを削減するために「Basic Ingest」を導入するメリットは小さいです。

参照: AWS IoT Core 料金

「Basic Ingest」は「メッセージブローカーをバイパス」しているため、あくまでも「選択肢を減らしている」点には注意してください。

2.やり方

「Basic Ingest」は以下の規則でトピックにメッセージをパブリッシュすれば実行できます。

$aws/rules/<実行したいIoTルール名>/<IoTルールのFROMで指定したトピック>

例えば、hoge/fooトピックを対象として「myrule」というルールを作成した場合は、以下のトピックにメッセージをパブリッシュすることで、「Basic Ingest」機能を利用することができます。

$aws/rules/myrule/hoge/foo

3.やってみた

まずは「Basic Ingest無し」でルールアクションを起動してみます。
その後に「Basic Ingest」機能を利用してアクションを実行してみます。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "iot:Publish"
      ],
      "Resource": [
        "arn:aws:iot:<region>:<awsAccountId>:topic/test/topic"
      ]
    },
    {
      "Effect": "Allow",
      "Action": [
        "iot:Connect"
      ],
      "Resource": [
        "arn:aws:iot:<region>:<awsAccountId>:client/test-*"
      ]
    }
  ]
}

Basic Ingest無し

test/topicトピックにメッセージをパブリッシュしてみます。
これだと、「Basic Ingest」無しで、普通にメッセージブローカーを介してルールエンジンにメッセージを送信している状態です。
ちゃんとS3にオブジェクトが格納できることが確認できました。

Basic Ingest有り

続いて、「Basic Ingest」で同様のアクションを実行できるかを確認します。

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": [
        "iot:Publish"
      ],
      "Resource": [
        "arn:aws:iot:<region>:<awsAccountId>:topic/$aws/rules/test_basic_ingest/test/topic"
      ]
    },
    {
      "Effect": "Allow",
      "Action": [
        "iot:Connect"
      ],
      "Resource": [
        "arn:aws:iot:<region>:<awsAccountId>:client/test-*"
      ]
    }
  ]
}

topic="$aws/rules/test_basic_ingest/test/topic"

下準備を施した後にメッセージをパブリッシュしてみると、ちゃんとアクションが実行できてS3にオブジェクトが格納できていることが確認できましたo(・∇・o)

4.まとめ

開発初期はまだ将来的にどうなるか分からないのでとりあえず選択肢の多い「メッセージブローカー」にPublishしていたものの、ある程度開発が落ち着いたら「これ、メッセージブローカーを介する必要なくない...?」となることもあるかもしれません。
もしメッセージングコストが高くつきそうな方は、「Basic Ingest」について頭の片隅に入れておくと、少しハッピーになれるかもしれません。

おまけ

topic()関数は使えるのだろうか、と気になったのですがちゃんと使えました。

基本的な取り込みが使用されている場合、トピック ($aws/rules/rule-name) の最初のプレフィックスは topic() 関数では使用できません。たとえば、次のトピックがあるとします。
$aws/rules/BuildingManager/Buildings/Building5/Floor2/Room201/Lights
topic() = "Buildings/Building5/Floor2/Room201/Lights"
topic(3) = "Floor2"

参照: topic(10 進数)

参照

• Reducing messaging costs with basic ingest
• 20201027 AWS Black Belt Online Seminar AWS IoT Core
• AWS IoT Core 料金
• topic(10 進数)