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

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

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

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

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

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

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

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

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

1. 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. アクションを選択 で、 AWS 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] (ルールの作成) ページに戻ります。

AWS IoT トピックアクションにメッセージを再発行する が 1 つ以上のアクションを設定する にリストされるようになりました。

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

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

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

ルールが発行するトピックをサブスクライブします: 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 クライアントで、サブスクリプション で、トピック に発行 を選択します。

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

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

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

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

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

1. MQTT クライアントでは、サブスクリプション の下に、以前にサブスクライブした 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 トピックのいずれかに正しいメッセージが発行されたことが確認できない場合は、トラブルシューティングのヒントを確認してください。