と同様の機能については AWS IoT Analytics、Amazon Kinesis 、Amazon S3、Amazon Athena をご覧ください。これらのサービスは、進化する分析要件を満たすためのスケーラビリティと柔軟性を高めます。ここでは、 https://aws-blogs-prod.amazon.com/iot/unlocking-scalable-iot-analytics-on-aws/について説明します。

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

Amazon CloudWatch Events を通じた遅延データ通知の取得

指定した時間枠のデータを使用してデータセットコンテンツを作成する場合、一部のデータが処理に間に合わない可能性があります。queryAction (SQL クエリ) を適用してデータセットを作成するときに QueryFilter に対して deltaTime オフセットを指定すれば遅延を許可できます。その後も、AWS IoT Analytics によりデルタ時間内に到着したデータは処理され、データセットコンテンツにはタイムラグがあります。遅延データ通知機能を使えば、データがデルタ時間後に到着した場合に AWS IoT Analytics では Amazon CloudWatch Events を通じて通知を送信できます。

AWS IoT Analytics コンソール、API、AWS Command Line Interface (AWS CLI)、または AWS SDK を使用して、データセット用に遅延データルールを指定することができます。

AWS IoT Analytics API では、LateDataRuleConfiguration オブジェクトはデータセットの遅延データルール設定を表します。このオブジェクトは、CreateDataset と UpdateDataset API オペレーションに関連する Dataset オブジェクトの一部です。

パラメータ

AWS IoT Analytics でデータセット用の遅延データルールを作成する場合は、次の情報を指定する必要があります。

遅延データルールの設定 (コンソール)

以下の手順は、AWS IoT Analytics コンソールでデータセットの遅延データルールを設定する方法を示しています。

遅延データルールの設定 (CLI)

AWS IoT Analytics API では、LateDataRuleConfiguration オブジェクトはデータセットの遅延データルール設定を表します。このオブジェクトは、CreateDataset と UpdateDataset に関連する Dataset オブジェクトの一部です。API、AWS CLI、または AWS SDK を使用して、データセット用に遅延データルールを指定することができます。次の例では AWS CLI を使用しています。

指定した遅延データルールを使用してデータセットを作成するには、以下のコマンドを実行します。このコマンドでは、dataset.json ファイルが現在のディレクトリ内にあると想定します。

aws iotanalytics create-dataset --cli-input-json file://dataset.json

dataset.json ファイルには次の内容が含まれます。

{
    "datasetName": "demo_dataset",
    "actions": [
        {
            "actionName": "myDatasetAction",
            "queryAction": {
                "filters": [
                    {
                        "deltaTime": {
                            "offsetSeconds": -180,
                            "timeExpression": "from_unixtime(time)"
                        }
                    }
                ],
                "sqlQuery": "SELECT * FROM demo_datastore"
            }
        }
    ],
    "retentionPeriod": {
        "unlimited": false,
        "numberOfDays": 90
    },
    "lateDataRules": [
        {
            "ruleConfiguration": {
                "deltaTimeSessionWindowConfiguration": {
                    "timeoutInMinutes": timeout
                }
            },
            "ruleName": "demo_rule"
        }
    ]
}

遅延データ通知を受信するためのサブスクライブ

CloudWatch Events で、AWS IoT Analytics から送信された遅延データ通知の処理方法を定義するルールを作成できます。CloudWatch Events により通知が受信されると、ルールで定義されている指定のターゲットアクションが呼び出されます。

CloudWatch Events ルール作成の前提条件

AWS IoT Analytics 用の CloudWatch Events ルールを作成する前に、以下を行う必要があります。

詳細については、Amazon CloudWatch Events ユーザーガイドの「CloudWatch Events とは」と「Amazon CloudWatch Events の開始方法」を参照してください。

遅延データ通知イベント

遅延データ通知のイベントでは次の形式を使用します。

{
	"version": "0",
	"id": "7f51dfa7-ffef-97a5-c625-abddbac5eadd",
	"detail-type": "IoT Analytics Dataset Lifecycle Notification",
	"source": "aws.iotanalytics",
	"account": "123456789012",
	"time": "2020-05-14T02:38:46Z",
	"region": "us-east-2",
	"resources": ["arn:aws:iotanalytics:us-east-2:123456789012:dataset/demo_dataset"],
	"detail": {
		"event-detail-version": "1.0",
		"dataset-name": "demo_dataset",
		"late-data-rule-name": "demo_rule",
		"version-ids": ["78244852-8737-4650-aa4d-3071a01338fa"],
		"message": null
	}
}

CloudWatch Events ルールを作成して遅延データ通知を受信する

以下の手順は、AWS IoT Analytics 遅延データ通知を Amazon SQS キューに送信するルールを作成する方法を示しています。