Amazon S3 を使用して AWS IoT SiteWise バッファされた送信先を追加する - AWS IoT SiteWise

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon S3 を使用して AWS IoT SiteWise バッファされた送信先を追加する

バッファされた送信先タイプを使用すると、データをリアルタイムで必要と AWS IoT SiteWise しない場合に、取り込みコストを節約できます。これにより、IoT データを Amazon S3 バケットに一時的に保存してからインポートできます AWS IoT SiteWise。または、データを S3 にアップロードして保存することもできます。インポートする予定があるかどうかは関係ありません AWS IoT SiteWise。これは、デバイスやゲートウェイからデータをバッチ処理およびバッファしてから取り込む場合に便利です AWS IoT SiteWise。このオプションでは、データは設定された頻度で Parquet 形式で指定された S3 バケットにアップロードされます。その後、このデータを AWS IoT SiteWise ストレージにインポートして、さらなる分析と処理を行うことができます。

Amazon S3 を使用してバッファされた送信先を追加するには

AWS IoT SiteWise コンソールまたは AWS CLI を使用して、Amazon S3 を使用してデータをバッファする送信先を SiteWise Edge ゲートウェイに追加します。

Console

AWS Management Console を使用して、Amazon S3 を使用してバッファされた AWS IoT SiteWise 送信先を追加します。

  1. AWS IoT SiteWise コンソールを開きます。

  2. ナビゲーションペインで、[Edge ゲートウェイ] を選択します。

  3. 送信先を追加するゲートウェイを選択します。

  4. 送信 セクションで、送信先の追加 を選択します。

  5. 送信先の追加ページで、送信先の詳細を入力します。

    1. 送信先名フィールドの送信先の名前

    2. AWS IoT SiteWise Amazon S3 for Destination type を使用してバッファされた を選択します。Amazon S3 を使用して AWS IoT SiteWise バッファされた は、データを Parquet 形式でバッチで Amazon Simple Storage Service に送信し、データをストレージに AWS IoT SiteWise インポートします。

  6. ゲートウェイデータを保存する場所の Amazon S3 URL を入力します。パスを参照するには、Browse S3 を選択します。バケットが追加されたら、表示を選択してバケットを表示することもできます。

  7. 時間枠を入力し、データのアップロード頻度の時間増分を選択して、ゲートウェイが Amazon S3 にデータをアップロードする頻度を指定します。 頻度値は 0 より大きく、30 日以下である必要があります。

  8. データストレージ設定で、ゲートウェイデータをインポートした後の対処方法を決定します AWS IoT SiteWise。データストレージについては、次の 2 つの決定事項があります。

    • インポートしたデータを AWS IoT SiteWise ストレージにコピーする場合は、データをストレージにコピーチェックボックスをオンにします。このオプションは、設定された Amazon S3 バケットからインポートされたデータを AWS IoT SiteWise ストレージに複製します。

    • Amazon S3 バケットから AWS IoT SiteWise ストレージにデータをインポートすることを選択した場合は、インポートが完了した後にインポートされたデータを削除するかどうかを指定することもできます。Amazon S3 からデータを削除チェックボックスをオンにして、 AWS IoT SiteWise ストレージにインポートした後、設定された Amazon S3 バケットからインポートされた日付を削除します。

  9. パスフィルターを送信先に追加します。詳細については、AWS IoT SiteWise Edge 送信先にパスフィルターを追加する を参照してください。

AWS CLI
例 : Amazon S3 を使用してバッファされた新しい AWS IoT SiteWise 送信先を作成する

UpdateGatewayCapabilityConfiguration API を使用してパブリッシャーを設定します。

capabilityNamespace パラメータを iotsitewise:publisher:3 に設定します。

{ "sources": [ { "type": "MQTT" } ], "destinations": [ { "type": "SITEWISE_BUFFERED", "name": "your-s3-destination-name", "config": { "targetBucketArn": "arn:aws:s3:::amzn-s3-demo-bucket/Optional/SomeFolder", "publishPolicy": { "publishFrequency": "15m", "localSizeLimitGB": 10 }, "siteWiseImportPolicy": { "enableSiteWiseStorageImport": true, "enableDeleteAfterImport": true, "bulkImportJobRoleArn": "arn:aws:iam::123456789012:role/your-role-name" } }, "filters": [ { "type": "PATH", "config": { "paths": [ "#" ] } } ] } ] }
例 : Amazon S3 を使用してバッファされた AWS IoT SiteWise 送信先を更新する

既存の AWS IoT SiteWise リアルタイム送信先を更新するには、まず DescribeGatewayCapabilityConfiguration API を使用して を検索しますdestinationId

パブリッシャーの名前空間: iotsitewise:publisher:3

{ "sources": [ { "type": "MQTT" } ], "destinations": [ { "id": "your-existing-destination-id", "type": "SITEWISE_BUFFERED", "name": "your-s3-destination-name", "config": { "targetBucketArn": "arn:aws:s3:::amzn-s3-demo-bucket/Optional/SomeFolder", "publishPolicy": { "publishFrequency": "15m", "localSizeLimitGB": 10 }, "siteWiseImportPolicy": { "enableSiteWiseStorageImport": true, "enableDeleteAfterImport": true, "bulkImportJobRoleArn": "arn:aws:iam::123456789012:role/your-role-name" } }, "filters": [ { "type": "PATH", "config": { "paths": [ "#" ] } } ] } ] }

以下の設定オプションは、 iotsitewise:publisher:3名前空間を使用する MQTT 対応ゲートウェイに固有のものです。

sources

産業機器から にデータを転送するためのデータソースを定義します AWS IoT SiteWise。MQTT 対応ゲートウェイの場合は、 を使用しますMQTT

タイプ: オブジェクトの配列

必須: はい

destinations

データの送信先を定義します。送信先は、Amazon S3 を使用してリアルタイムまたはバッファリングされます。少なくとも 1 つの送信先オブジェクトが必要ですが、空の配列を追加できます。ゲートウェイごとに 1 つのリアルタイム送信先を設定できます。詳細については、「AWS IoT SiteWise Edge の送信先を理解する」を参照してください。

タイプ: オブジェクトの配列

必須: はい

id

送信先の一意の識別子。既存の送信先 ID を指定するか、空白のままにすると、送信先に対して新しい ID が自動的に生成されます。

タイプ: 文字列

必須: いいえ

type

タイプ: 宛先 オプションには、 SITEWISE_REALTIMEと がありますSITEWISE_BUFFEREDSITEWISE_BUFFERED を選択してください。

  • SITEWISE_REALTIME (デフォルト) – データをリアルタイムで AWS IoT SiteWise ストレージに直接送信します。詳細については、「AWS IoT SiteWise Edge リアルタイム送信先を追加する」を参照してください。

  • SITEWISE_BUFFERED – Parquet 形式でデータをバッチで Amazon S3 に送信し、 AWS IoT SiteWise ストレージにインポートします。

タイプ: 文字列

必須: はい

name

送信先の一意の名前。

タイプ: 文字列

必須: はい

config

JSON 形式の送信先タイプに固有の設定。設定は、リアルタイム送信先とバッファ送信先によって異なります。

型: オブジェクト

必須: はい

targetBucketArn

発行先のバケット ARN。 AWS IoT SiteWise と Amazon S3 の両方 AWS リージョン に同じ を選択します。プレフィックスを選択した場合、1~255 文字である必要があります。

注記

AWS IoT SiteWiseゲートウェイを含む は、指定された S3 バケット全体にアクセスできます。バッファされたデータインジェストには専用バケットを使用することをお勧めします。

タイプ: 文字列

必須: はい

publishPolicy

発行ポリシーの詳細。

型: オブジェクト

必須: はい

publishFrequency

SiteWise Edge ゲートウェイが Amazon S3 バケットに発行する頻度。Amazon S3 へのデータのアップロード頻度は、0 分以上 30 日以下である必要があります。発行頻度の有効期間を指定するd場合はm、、h、および を使用できます。m は分数、hは時数、dは日数を表します。デフォルト値は 15 分です。

タイプ: 文字列

必須: はい

localSizeLimitGB

ローカルディスクに書き込まれるファイルの最大サイズを GB 単位で指定します。このしきい値を超えると、パブリッシャーはバッファされたすべてのデータを宛先に発行します。

タイプ: 整数

必須: はい

siteWiseImportPolicy

データをインポートするためのインポートポリシーの詳細 AWS IoT SiteWise。

型: オブジェクト

必須: はい

enableSiteWiseStorageImport

Amazon S3 バケットから AWS IoT SiteWise ストレージにデータをインポートtrueするには、これを に設定します。最初は、 でデータのコピーを作成します AWS IoT SiteWise。次に、 enableDeleteAfterImportを true に設定すると、S3 内のデータはコピー後に削除されます AWS IoT SiteWise。料金への影響が適用されます。デフォルト値は true です。

型: ブール値

必須: はい

enableDeleteAfterImport

AWS IoT SiteWise ストレージへの取り込み後に Amazon S3 バケット内のファイルtrueを削除するには、これを に設定します。デフォルト値は true です。

型: ブール値

必須: はい

bulkImportJobRoleArn

データ取り込み中に Amazon S3 からバッファされたデータを読み取るために が AWS IoT SiteWise 引き受ける IAM ロールの ARN。このロールは、エッジデバイスが AWS IoT SiteWise APIs で呼び出して一括インポートプロセスを開始する場合に使用されます。

注記

enableSiteWiseStorageImport が に設定されている場合true、このパラメータは必須です。

タイプ: 文字列

必須: いいえ

送信先のパスフィルターを追加します。詳細については、「AWS IoT SiteWise Edge 送信先にパスフィルターを追加する」を参照してください。