チュートリアル: MQTT メッセージの再発行

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

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

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

1. [Name] (名前) で、ルールの名前を入力します。このチュートリアルでは、republish_temp という名前を付けます。

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

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

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

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

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

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

   SELECT topic(2) as device_id, temperature FROM 'device/+/data'

   このステートメント:

   • device/+/data トピックフィルターに一致するトピックを持つ MQTT メッセージをリッスンします。

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

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

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

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

2. [Select an action] (アクションの選択) で、[Republish a message to an AWS IoT topic] (IoT トピックにメッセージを再発行) を選択します。

3. アクションリストの一番下で、[Configure action] (アクションを設定) を選択すると、選択したアクションの設定ページが開きます。

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

1. [Topic] (トピック) で、device/data/temp と入力します。これは、このルールが発行するメッセージの MQTT トピックです。

2. [Quality of Service] (サービスの品質) で、[0 - The message is delivered zero or more times] (0 - メッセージは 0 回以上配信されます。) を選択します。

3. このアクションを実行するための AWS IoT アクセス権限を付与するロールを選択または作成するには、

   1. [ロールの作成] を選択します。[Create a new role] (新しいロールを作成) ダイアログボックスが開きます。

   2. 新しいロールを説明する名前を入力します。このチュートリアルでは、republish_role を使用します。

      新しいロールを作成すると、ルールアクションを実行するための正しいポリシーが作成され、新しいロールにアタッチされます。このルールアクションのトピックを変更するか、別のルールアクションでこのロールを使用する場合は、そのロールのポリシーを更新して、新しいトピックまたはアクションを承認する必要があります。既存のロールを更新するには、このセクションで [Update role] (ロールの更新) を選択します。

   3. [Create Role] (ロールの作成) を選択してロールを作成し、ダイアログボックスを閉じます。

4. [Add action] (アクションの追加) を選択してアクションをルールに追加し、[Create a rule] (ルールの作成) ページに戻ります。

[Republish a message to an AWS IoT topic] (IoT トピックにメッセージを再発行する) アクションが [Set one or more actions] (1 つ以上のアクションを設定する) に表示されるようになりました。

新しいアクションのタイルの [Republish a message to an AWS IoT topic] (IoT トピックにメッセージを再発行する) をクリックすると、再発行アクションが発行されるトピックが表示されます。

このルールに追加するルールアクションはこれだけです。

[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 が表示されます。

ルールが発行するトピックをサブスクライブします: device/data/temp。

1. [Subscriptions] (サブスクリプション) で、[Subscribe to a topic] (トピックへサブスクライブする) を再度選択し、[Subscription topic] (サブスクリプショントピック) で、再発行されたメッセージのトピック device/data/temp を入力します。

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

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

   [Subscriptions] (サブスクリプション) 列の [device/+/data] の下に device/data/temp が表示されます。

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

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

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

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

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

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

送信されたメッセージを確認します。

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

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

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

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

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

   {
     "device_id": "22",  
     "temperature": 28
   }

   device_id 値は引用符で囲まれた文字列で、temperature 値は数値であることに注意してください。これは、topic() 関数が入力メッセージのトピック名から文字列を抽出している一方で、temperature 値は入力メッセージのペイロードの数値を使用することによるものです。

   device_id 値を数値にしたい場合は、ルールクエリステートメントで topic(2) を次のように置き換えます。

   cast(topic(2) AS DECIMAL)

   topic(2) 値を数値にキャストすることは、トピックのその部分に数字のみが含まれている場合にのみ機能することに注意してください。

正しいメッセージが device/data/temp トピックに発行されたことが確認できれば、ルールは機能しています。再発行ルールアクションの詳細については、次のセクションを参照してください。

device/+/data または device/data/temp トピックのいずれかに正しいメッセージが発行されたことが確認できない場合は、トラブルシューティングのヒントを確認してください。