チュートリアル: AWS Lambda 関数を使用して通知をフォーマットする

新しい AWS Lambda 関数を作成する

1. AWS Lambda コンソールで、[関数の作成] を選択します。

2. [Create function] (関数の作成) で、[Use a blueprint] (ブループリントを使用) を選択します。

   hello-world-python ブループリントを検索して選択し、[Configure] (設定) を選択します。

3. [Basic information] (基本的な情報) で、次の操作を実行します。

   1. [Function name] (関数名) で、関数の名前 format-high-temp-notification を入力します。

   2. [Execution role] (実行ロール) で、[Create a new role from AWS policy templates] (AWS ポリシーテンプレートから新しいロールを作成) を選択します。

   3. [Role name] (ロール名) で、新しいロールの名前 format-high-temp-notification-role を入力します。

   4. [Policy templates - optional] (ポリシーテンプレート - オプション) で、[Amazon SNS publish policy] (Amazon SNS 発行ポリシー) を検索して選択します。

   5. [Create function] を選択します。

ブループリントコードを変更して、Amazon SNS 通知をフォーマットして送信します。

1. 関数を作成すると、format-high-temp-notification の詳細ページが表示されます。表示されない場合は、[Lambda Functions] (Lambda 関数) ページから開きます。

2. format-high-temp-notification の詳細ページで、[Configuration] (設定) タブを選択し、[Function code] (関数コード) パネルまでスクロールします。

3. [Function code] (関数コード) ウィンドウの [Environment] (環境) ペインで、Python ファイル lambda_function.py を選択します。

4. [Function code] (関数コード) ウィンドウで、ブループリントから元のプログラムコードをすべて削除し、このコードに置き換えます。

   import boto3
   #
   #   expects event parameter to contain:
   #   {
   #       "device_id": "32",
   #       "reported_temperature": 38,
   #       "max_temperature": 30,
   #       "notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
   #   }
   # 
   #   sends a plain text string to be used in a text message
   #
   #      "Device {0} reports a temperature of {1}, which exceeds the limit of {2}."
   #   
   #   where:
   #       {0} is the device_id value
   #       {1} is the reported_temperature value
   #       {2} is the max_temperature value
   #
   def lambda_handler(event, context):
   
       # Create an SNS client to send notification
       sns = boto3.client('sns')
   
       # Format text message from data
       message_text = "Device {0} reports a temperature of {1}, which exceeds the limit of {2}.".format(
               str(event['device_id']),
               str(event['reported_temperature']),
               str(event['max_temperature'])
           )
   
       # Publish the formatted message
       response = sns.publish(
               TopicArn = event['notify_topic_arn'],
               Message = message_text
           )
   
       return response

5. [デプロイ] を選択します。

新しいウィンドウで、チュートリアル: Amazon SNS 通知の送信 の方法に関するチュートリアルから、Amazon SNS トピックの Amazon リソースネーム (ARN) を検索します。

1. 新しいウィンドウで、Amazon SNS コンソールの [Topics] (トピック) ページを開きます。

2. [Topics] (トピック) ページで、Amazon SNS トピックのリストから high_temp_notice 通知トピックを見つけます。

3. 次のステップで使用する high_temp_notice 通知トピックの ARN を見つけます。

Lambda 関数のテストケースを作成します。

1. コンソールの [Lambda Functions] (Lambda 関数) ページの format-high-temp-notification ページで、ページの右上にある (無効に見える) [Select a test event] (テストイベントの選択) を選択し、[Configure test events] (テストイベントの設定) を選択します。

2. [Configure test event] (テストイベントの設定) で、[Create new test event] (新しいテストイベントの作成) を選択します。

3. [Event name] (イベント名) で、SampleRuleOutput と入力します。

4. [Event name] (イベント名) の下の JSON エディタで、このサンプル JSON ドキュメントを貼り付けます。これは、AWS IoT ルールが Lambda 関数に送信する内容の例です。

   {
     "device_id": "32",
     "reported_temperature": 38,
     "max_temperature": 30,
     "notify_topic_arn": "arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice"
   }

5. high_temp_notice 通知トピックの ARN があるウィンドウを参照し、ARN 値をコピーします。

6. JSON エディターの notify_topic_arn 値を通知トピックの ARN に置き換えます。

   AWS IoT ルールを作成するときにこの ARN 値を再度使用できるように、このウィンドウを開いたままにします。

7. [Create] を選択します。

サンプルデータを使用して関数をテストします。

1. format-high-temp-notification の詳細ページの右上で、SampleRuleOutput が [Test] (テスト) ボタンの横に表示されていることを確認します。表示されない場合は、利用可能なテストイベントのリストから選択します。

2. サンプルルール出力メッセージを関数に送信するには、[Test] (テスト) を選択します。

AWS IoT コンソールの [Rules] (ルール) ハブを開きます。

[Rules] (ルール) で新しいルールの作成を開始するには、[Create] (作成) を選択します。

[Create a rule] (ルールを作成) の上部で、次のように操作します。

1. [Name] (名前) で、ルールの名前 wx_friendly_text を入力します。

   ルール名は、AWS アカウント とリージョン内で一意である必要があります。また、スペースを含めることはできません。この名前にアンダースコア文字を使用して、ルールの名前の 2 つの単語を区切りました。

2. [Description] (説明) で、ルールの説明を入力します。

   わかりやすい説明を使用すると、このルールの動作と作成した理由を簡単に思い出すことができます。説明は必要なだけ長くすることができるので、できるだけ詳述してください。

[Create a rule] (ルールを作成) の [Rule query statement] (ルールクエリステートメント) で、以下を実行します。

1. [Using SQL version] (SQL バージョンの使用) で、2016-03-23 を選択します。

2. [Rule query statement] (ルールクエリステートメント) 編集ボックスで、ステートメントを入力します。

   SELECT 
     cast(topic(2) AS DECIMAL) as device_id, 
     temperature as reported_temperature,
     30 as max_temperature,
     'arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice' as notify_topic_arn
   FROM 'device/+/data' WHERE temperature > 30

   このステートメント:

   • device/+/data トピックフィルターに一致し、temperature 値が 30 より大きいトピックを含む MQTT メッセージをリッスンします。

   • トピック文字列から 2 番目の要素を選択し、それを 10 進数に変換してから、device_id フィールドに割り当てます。

   • メッセージペイロードから temperature フィールドの値を選択し、それを reported_temperature フィールドに割り当てます。

   • 制限値を表す定数値 30 を作成し、それを max_temperature フィールドに割り当てます。

   • notify_topic_arn フィールドの定数値を作成します。

3. high_temp_notice 通知トピックの ARN があるウィンドウを参照し、ARN 値をコピーします。

4. ルールクエリステートメントエディタの ARN 値 (arn:aws:sns:us-east-1:57EXAMPLE833:high_temp_notice) を通知トピックの ARN に置き換えます。

[Set one or more actions] (1 つ以上のアクションを設定) で、以下を実行します。

1. このルールのルールアクションのリストを開くには、[Add action] (アクションの追加) を選択します。

2. [Select an action] (アクションを選択してください) で、[Send a message to a Lambda function] (Lambda 関数にメッセージを送信する) を選択します。

3. 選択したアクションの設定ページを開くには、アクションリストの下部にある [Configure action] (アクションの設定) を選択します。

[Configure action] (アクションの設定) で、次のとおり実行します。

1. [Function name] (関数名) で、[Select] (選択) を選択します。

2. format-high-temp-notification を選択します。

3. [Configure action] (アクションの設定) の下部で、[Add action] (アクションの追加) を選択します。

4. ルールを作成するには、[Create a rule] (ルールの作成) の下部にある [Create rule] (ルールの作成) を選択します。

AWS IoT コンソールの MQTT クライアントで、入力トピック (この場合は device/+/data) をサブスクライブします。

1. MQTT クライアントの [Subscription] (サブスクリプション) で、[Subscribe to topic] (トピックへのサブスクライブ) を選択します。

2. [Subscription topic] (サブスクリプショントピック) で、入力トピックフィルター device/+/data のトピックを入力します。

3. 残りのフィールドはデフォルト設定のままにします。

4. [Subscribe to topic] を選択します。

   [Subscriptions] (サブスクリプション) 列の [Publish to a topic] (トピックへの発行) の下に device/+/data が表示されます。

特定のデバイス ID device/32/data を使用して入力トピックにメッセージを発行します。ワイルドカード文字を含む MQTT トピックには発行できません。

1. MQTT クライアントの [Subscription] (サブスクリプション) で、[Publish to topic] (トピックに発行) を選択します。

2. [Publish] (発行) フィールドに、入力トピック名 device/32/data を入力します。

3. ここに表示されているサンプルデータをコピーし、トピック名の下にある編集ボックスにサンプルデータを貼り付けます。

   {
     "temperature": 38,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. MQTT メッセージを発行するには、[Publish to topic] (トピックに発行) を選択します。

テキストメッセージが送信されたことを確認します。

1. MQTT クライアントの [Subscriptions] (サブスクリプション) の下に、以前にサブスクライブしたトピックの隣に緑色のドットが表示されます。

   緑色のドットは、最後にメッセージを表示してから 1 つ以上の新しいメッセージが受信されたことを示します。

2. [Subscriptions] (サブスクリプション) で [device/+/data] を選択して、メッセージペイロードが今発行したものと一致し、次のようになっていることを確認します。

   {
     "temperature": 38,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

3. SNS トピックのサブスクライブに使用した電話を確認し、メッセージペイロードの内容が次のようになっていることを確認します。

   Device 32 reports a temperature of 38, which exceeds the limit of 30.

   メッセージトピックのトピック ID 要素を変更する場合、topic(2) 値を数値にキャストすることは、メッセージトピックのその要素に数字のみが含まれている場合にのみ機能することに注意してください。

温度が制限を超えていない MQTT メッセージの送信を試みます。

1. MQTT クライアントの [Subscription] (サブスクリプション) で、[Publish to topic] (トピックに発行) を選択します。

2. [Publish] (発行) フィールドに、入力トピック名 device/33/data を入力します。

3. ここに表示されているサンプルデータをコピーし、トピック名の下にある編集ボックスにサンプルデータを貼り付けます。

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. MQTT メッセージを送信するには、[Publish to topic] (トピックに発行) を選択します。

device/+/data サブスクリプションで送信したメッセージが表示されますが、温度値がルールクエリステートメントの最大温度を下回っているため、テキストメッセージは受信されません。

正しい動作が確認できない場合は、トラブルシューティングのヒントを確認してください。