チュートリアル: デバイスデータの DynamoDB テーブルへの保存

DynamoDB コンソールを開き、[Create table] (テーブルの作成) を選択します。

Create table (テーブルの作成) の

1. [Table name] (テーブル名) で、テーブル名 wx_data を入力します。

2. [Partition key] (パーティションキー) で sample_time と入力し、フィールドの横にあるオプションリストで Number を選択します。

3. [Sort key] (ソートキー) で device_id と入力します。フィールドの横にあるオプションリストで Number を選択します。

4. ページの下部で、[Create] (作成) を選択します。

AWS IoT コンソールの [Rules] (ルール) ハブを開きます。または、 AWS Management Console 内で AWS IoT ホームページを開き、メッセージルーティング＞ルール に移動できます。

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

[Rule properties] (ルールのプロパティ) の

1. [Rule name] (ルール名) で wx_data_ddb と入力します。

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

2. [Rule description] (ルールの説明) で、ルールを説明します。

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

[次へ] を選択して続行します。

SQL ステートメント で：

1. SQL バージョン で、 を選択します2016-03-23。

2. SQL ステートメント編集ボックスに、 ステートメントを入力します。

   SELECT temperature, humidity, barometer,
     wind.velocity as wind_velocity,
     wind.bearing as wind_bearing,
   FROM 'device/+/data'

   このステートメント:

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

   • wind 属性の要素を個々の属性としてフォーマットします。

   • temperature、humidity、および barometer 属性を変更せずに渡します。

[次へ] を選択して続行します。

[Rule actions] (ルールのアクション) で

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

   注記

   ルールアクションとして D ynamoDBv2 ではなく DynamoDB を選択してください。

2. [Table name] (テーブル名) で、前の手順で作成した DynamoDB テーブルの名前 wx_data を選択します。

   [Partition key type] (パーティションキータイプ) および [Sort key type] (ソートキータイプ) のフィールドには、DynamoDB テーブルの値が入力されます。

3. [パーティションキー] に「sample_time」と入力します。

4. [パーティションキーの値] に「${timestamp()}」と入力します。

   これは、このルールで使用する 置換テンプレート の最初のものです。メッセージペイロードの値を使用する代わりに、timestamp 関数から返された値を使用します。詳細については、AWS IoT Core デベロッパーガイドの 「タイムスタンプ」を参照してください。

5. [Sort key] (ソートキー) に「device_id」と入力します。

6. [ソートキー値] に「${cast(topic(2) AS DECIMAL)}」と入力します。

   これは、このルールで使用する 置換テンプレート の 2 番目のものです。2 番目の要素の値を、キーの数値形式に一致するDECIMAL値にキャストした後、デバイスの ID であるトピック名に挿入します。トピックの詳細については、AWS IoT Core デベロッパーガイドの「トピック」を参照してください。または、キャスティングの詳細については、AWS IoT Core デベロッパーガイドの「キャスト」を参照してください。

7. [この列にメッセージデータを書き込む] に device_data と入力します。

   これにより、DynamoDB テーブルに device_data 列が作成されます。

8. [オペレーション] は空白のままにします。

9. IAM ロール で、新しいロールの作成 を選択します。

10. [Create role] (ロールの作成) ダイアログボックスの [Role name] (ロール名) に [wx_ddb_role] と入力します。この新しいロールには、プレフィックスがaws-iot-rule「」のポリシーが自動的に含まれ、wx_data_ddbルールが作成した DynamoDB wx_data テーブルにデータを送信できるようになります。

11. IAM ロール で、 を選択しますwx_ddb_role。

12. ページの最下部にある [Next] (次へ) を選択します。

[Review and create] (確認と作成) ページの最下部で、[Create] (作成) を選択して、ルールを作成します。

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

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

2. [Topic filter] (トピックフィルター) に、入力トピックフィルター device/+/data のトピックを入力します。

3. [Subscribe] (サブスクライブ) を選択します。

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

1. MQTT クライアントで、トピック に発行 を選択します。

2. [Topic name] (トピック名) に、入力トピックの名前 device/22/data を入力します。

3. [Message payload] (メッセージペイロード) に、次のサンプルデータを入力します。

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

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

5. MQTT クライアントで、トピック にサブスクライブを選択します。[Subscribe] (サブスクライブ) 列で、device/+/data サブスクリプションを選択します。前のステップのサンプルデータがそこに表示されていることを確認します。

ルールが作成した DynamoDB テーブルの行を確認します。

1. AWS IoT コンソール の DynamoDB Tables ハブで、wx_data を選択し、Items タブを選択します。

   [Items] (アイテム) タブを既に開いている場合は、テーブルのヘッダーの右上にある更新アイコンを選択して、表示を更新する必要がある場合があります。

2. テーブルの sample_time 値はリンクであり、オープンであることに注意してください。最初のメッセージを送ったばかりの場合は、そのメッセージだけがリストに表示されます。

   このリンクには、テーブルのその行のすべてのデータが表示されます。

3. device_data エントリを展開して、ルールクエリステートメントの結果のデータを表示します。

4. この表示で使用できるデータのさまざまな表現を詳しく確認します。このディスプレイでデータを編集することもできます。

5. このデータ行の確認が終了したら、加えた変更を保存するには [Save] (保存) を選択し、変更を保存せずに終了するには [Cancel] (キャンセル) を選択します。