チュートリアル: 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. 実行ロール で、 AWS ポリシーテンプレート から新しいロールを作成する を選択します。

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

   4. ポリシーテンプレート - オプション で、Amazon SNS パブリッシュポリシー を検索して選択します。

   5. [Create function (関数の作成)] を選択します。

Amazon SNS通知をフォーマットして送信するように設計図コードを変更します。

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

2. format-high-temp-notification 詳細ページで、設定タブを選択し、関数コードパネルにスクロールします。

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 リソースネーム (ARN) を検索しますチュートリアル: Amazon SNS通知の送信。

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

2. トピックページで、Amazon トピックのリストで high_temp_notice 通知SNSトピックを見つけます。

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

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

1. コンソールの Lambda Functions ページで、format-high-temp-notification詳細ページで、ページの右上隅にあるテストイベントを選択 (無効になっているように見える場合でも) を選択し、テストイベントの設定 を選択します。

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

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

4. イベント名 の下の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に表示されることを確認します。表示されない場合は、利用可能なテストイベントのリストから選択します。

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

AWS IoT コンソール のルールハブを開きます。

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

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

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

   ルール名は AWS アカウント および リージョン内で一意でなければならず、スペースを含めることはできません。この名前にアンダースコア文字を使用して、ルールの名前の 2 つの単語を区切りました。

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

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

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

1. 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

   このステートメント:

   • トピックフィルターに一致し、temperature値が 30 を超えるdevice/+/dataトピックを含む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] (ルールの作成) を選択します。

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

1. MQTT クライアントで、サブスクリプション で、トピック にサブスクライブを選択します。

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

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

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

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

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

1. MQTT クライアントで、サブスクリプション で、トピック に発行 を選択します。

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

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

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

4. MQTT メッセージを発行するには、「トピック に発行」を選択します。

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

1. MQTT クライアントでは、サブスクリプション の下に、以前にサブスクライブしたトピックの横に緑色のドットがあります。

   緑色のドットは、最後にメッセージを表示してから 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 クライアントで、サブスクリプション で、トピック に発行 を選択します。

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

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

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

4. MQTT メッセージを送信するには、「トピック に発行する」を選択します。

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

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