リモート監視の事前構成済みソリューションのチュートリアル

IoT Suite リモート監視の事前構成済みソリューションは、遠隔地で実行されている複数のコンピューターを対象としたエンド ツー エンドの監視ソリューションの実装です。 このソリューションは、主要な Azure サービスを組み合わせることで、ビジネス シナリオの汎用的な実装を実現したものです。 このソリューションを実装の出発点として使用し、お客様固有のビジネス要件を満たすようにカスタマイズすることができます。

この記事では、リモート監視ソリューションのしくみについて理解しやすいように、その主な構成要素をいくつか取り上げて説明します。 この知識は以下の作業に役立ちます。

• ソリューションの問題のトラブルシューティングを行う。
• 独自の要件を満たすためにソリューションをカスタマイズする方法を計画する。
• Azure サービスを利用する独自の IoT ソリューションを設計する。

論理アーキテクチャ

次の図は、事前構成済みソリューションの論理コンポーネントの概要を示したものです。

Microservices および Docker コンテナー

リモート監視は、マイクロサービス アーキテクチャを利用した最初の構成済みソリューションです。 ソリューションは、.NET と Java の両方で使用できます。 マイクロサービスは、開発スピードを損なうことなく、拡張性と柔軟性を実現する (コンテナーを個別にスケーリングできることで) 一般的なパターンとして出現しました。 マイクロサービスは、コードを区分し、適切に定義されたインターフェイスを提供して、ソリューションを理解しやすく、モノリシック化を低減します。 さらに、現在のソリューション アクセラレータを拡張して、収益化可能な完成したソリューションを構築したいと考えるパートナーにとって、選択肢を拡げます。

Docker Containers の詳細

• Docker のインストール
• リモート監視のための一般的な Docker コマンド
• Docker の概要

シミュレートされたデバイス

事前構成済みソリューションにおいて、シミュレートされたデバイスは冷却装置 (建物のエアコンや施設の空気処理ユニットなど) を表します。 事前構成済みのソリューションをデプロイすると、Azure WebJob で動作する 4 つのシミュレーション デバイスが自動的にプロビジョニングされます。 シミュレーション デバイスを使用することで、ソリューションの動作を簡単に調査することができます。物理デバイスをデプロイする必要はありません。 実際の物理デバイスをデプロイするには、チュートリアル「デバイスをリモート監視構成済みソリューションに接続する」を参照してください。

デバイスからクラウドへのメッセージ

シミュレーション デバイスはそれぞれ、次の種類のメッセージを IoT Hub に送信することができます。

プロパティとデバイス ツイン

シミュレートされたデバイスは、以下のデバイス プロパティを IoT ハブのツインに "報告されるプロパティ" として送信します。 デバイスは、スタートアップ時とデバイス状態の変更コマンドまたはメソッドへの応答時に、報告されるプロパティを送信します。

シミュレーターは、シミュレートされたデバイスのこれらのプロパティをサンプル値と共に送信します。 シミュレーターがシミュレートされたデバイスを初期化するたびに、デバイスは事前定義されたメタデータを報告されるプロパティとして IoT Hub に報告します。 報告されるプロパティは、デバイスのみが更新できます。 報告されるプロパティを変更するには、ソリューション ポータルで必要なプロパティを設定します。 以下の操作は、デバイスが行います。

1. IoT ハブから必要なプロパティを定期的に取得します。
2. 必要なプロパティの値で構成を更新します。
3. 新しい値を、報告されるプロパティとしてハブに返信します。

ソリューションのダッシュボードで、"必要なプロパティ" を使用し、デバイス ツインを使用して、デバイスのプロパティを設定することができます。 デバイスは通常、内部状態を更新し、報告されるプロパティとして変更を報告するために、ハブから必要なプロパティの値を読み取ります。

メソッド

シミュレートされたデバイスは、ソリューション ポータルから IoT ハブを通じて呼び出された以下のメソッド (ダイレクト メソッド) を処理することができます。

いくつかのメソッドは、報告されるプロパティを使用して、進行状況を報告します。 たとえば、InitiateFirmwareUpdate メソッドは、デバイスでの非同期的な更新の実行をシミュレートします。 このメソッドはデバイスですぐに制御を返しますが、非同期タスクは報告されるプロパティを使用して、状態の更新をソリューションのダッシュボードに返信し続けます。

コマンド

シミュレートされたデバイスは、ソリューション ポータルから IoT ハブを通じて送信される以下のコマンド (cloud-to-device メッセージ) を処理することができます。

IoT Hub

IoT ハブは、デバイスから送信されたデータをクラウドに取り込んで、Azure Stream Analytics (ASA) ジョブから利用できる状態にします。 ストリームの ASA ジョブは、それぞれ別個の IoT Hub コンシューマー グループを使用して、デバイスから送られたメッセージのストリームを読み取ります。

ソリューションの IoT ハブは、以下の操作も行います。

• ポータルへの接続を許可されているすべてのデバイスの ID と認証キーを格納する ID レジストリを維持します。 ID レジストリを通じて、デバイスを有効および無効にすることができます。
• ソリューション ポータルに代わって、デバイスにコマンドを送信します。
• ソリューション ポータルに代わって、デバイスのメソッドを呼び出します。
• すべての登録済みデバイスのデバイス ツインを保持します。 デバイス ツインは、デバイスによって報告されたプロパティの値を格納します。 また、デバイスが次回の接続時に取得できるように、ソリューション ポータルで設定された必要なプロパティも格納します。
• 複数のデバイスのプロパティを設定したり、複数のデバイスに対してメソッドを呼び出したりするジョブをスケジュールします。

Azure Stream Analytics

リモート監視ソリューションでは、IoT ハブが受け取ったデバイス メッセージは、Azure Stream Analytics (ASA) によって他のバックエンド コンポーネントにディスパッチされて処理されるか、保存されます。 メッセージの内容に基づく特定の機能が、各 ASA ジョブによって実行されます。

ジョブ 1: デバイス情報 は、受信メッセージ ストリームからデバイス情報メッセージをフィルター処理し、フィルター処理されたメッセージをイベント ハブ エンドポイントに送信します。 デバイスは、起動時および SendDeviceInfo コマンドへの応答時に、デバイス情報メッセージを送信します。 このジョブは、次のクエリ定義を使用して device-info メッセージを識別します。

SELECT * FROM DeviceDataStream Partition By PartitionId WHERE  ObjectType = 'DeviceInfo'

このジョブの出力は、後続の処理のためにイベント ハブに出力されます。

ジョブ 2: 規則は、デバイスごとのしきい値に対して、温度と湿度の受信テレメトリ値を評価します。 しきい値の値は、ソリューション ポータルから利用できる規則エディターで設定します。 デバイスと値の各ペアは、参照データとして Stream Analytics が読み取る BLOB に、タイムスタンプに基づいて格納されます。 このジョブでは、空以外の値が、デバイスに設定された設定しきい値と比較されます。 ">" 条件を超えた場合、ジョブはしきい値を超えたことを示す アラーム イベントを出力し、デバイス、値、およびタイムスタンプの値を提供します。 このジョブは、アラームのトリガーとなるテレメトリ メッセージを次のクエリ定義によって識別します。

WITH AlarmsData AS 
(
SELECT
     Stream.IoTHub.ConnectionDeviceId AS DeviceId,
     'Temperature' as ReadingType,
     Stream.Temperature as Reading,
     Ref.Temperature as Threshold,
     Ref.TemperatureRuleOutput as RuleOutput,
     Stream.EventEnqueuedUtcTime AS [Time]
FROM IoTTelemetryStream Stream
JOIN DeviceRulesBlob Ref ON Stream.IoTHub.ConnectionDeviceId = Ref.DeviceID
WHERE
     Ref.Temperature IS NOT null AND Stream.Temperature > Ref.Temperature

UNION ALL

SELECT
     Stream.IoTHub.ConnectionDeviceId AS DeviceId,
     'Humidity' as ReadingType,
     Stream.Humidity as Reading,
     Ref.Humidity as Threshold,
     Ref.HumidityRuleOutput as RuleOutput,
     Stream.EventEnqueuedUtcTime AS [Time]
FROM IoTTelemetryStream Stream
JOIN DeviceRulesBlob Ref ON Stream.IoTHub.ConnectionDeviceId = Ref.DeviceID
WHERE
     Ref.Humidity IS NOT null AND Stream.Humidity > Ref.Humidity
)

SELECT *
INTO DeviceRulesMonitoring
FROM AlarmsData

SELECT *
INTO DeviceRulesHub
FROM AlarmsData

このジョブの出力は、後続の処理のためにイベント ハブに送信され、各アラートの詳細は Blob Storage に保存されます。ソリューション ポータルは、ここからアラート情報を読み取ることができます。

ジョブ 3: テレメトリ は、2 とおりの方法で、受信デバイス テレメトリ ストリームに対して動作します。 1 つ目の方法では、デバイスから送信されたすべてのテレメトリ メッセージを長期保管を目的とした永続的な Blob Storage に送信します。 2 つ目の方法では、5 分間のスライディング ウィンドウで湿度の平均値、最小値、最大値を計算し、そのデータを Blob Storage に送信します。 ソリューション ポータルは、Blob Storage からテレメトリ データを読み取ってグラフに反映します。 このジョブは、次のクエリ定義を使用します。

WITH 
    [StreamData]
AS (
    SELECT
        *
    FROM [IoTHubStream]
    WHERE
        [ObjectType] IS NULL -- Filter out device info and command responses
) 

SELECT
    IoTHub.ConnectionDeviceId AS DeviceId,
    Temperature,
    Humidity,
    ExternalTemperature,
    EventProcessedUtcTime,
    PartitionId,
    EventEnqueuedUtcTime,
    * 
INTO
    [Telemetry]
FROM
    [StreamData]

SELECT
    IoTHub.ConnectionDeviceId AS DeviceId,
    AVG (Humidity) AS [AverageHumidity],
    MIN(Humidity) AS [MinimumHumidity],
    MAX(Humidity) AS [MaxHumidity],
    5.0 AS TimeframeMinutes 
INTO
    [TelemetrySummary]
FROM [StreamData]
WHERE
    [Humidity] IS NOT NULL
GROUP BY
    IoTHub.ConnectionDeviceId,
    SlidingWindow (mi, 5)

Event Hubs

ASA ジョブであるデバイス情報と規則は、そのデータを Event Hubs に出力し、WebJob で実行されているイベント プロセッサへと確実に転送します。

Azure Storage

このソリューションは、対象となるデバイスから未加工のまま集約されたすべてのテレメトリ データを Azure Blob Storage に永続化します。 ポータルは、Blob Storage からテレメトリ データを読み取ってグラフに反映します。 ソリューション ポータルにアラートを表示する際は、しきい値の設定をテレメトリ値がいつ上回ったのかを記録した Blob Storage からデータが読み取られます。 また、ソリューション ポータルで設定したしきい値を記録するときにも Blob Storage が使用されます。

WebJobs

このソリューションの WebJob は、デバイス シミュレーターに加え、Azure WebJob 内で実行されるイベント プロセッサをホストします。このイベント プロセッサによって、コマンドの応答が処理されます。 デバイス コマンドの履歴 (Cosmos DB データベースに格納されています) を更新するために、コマンド応答メッセージが使用されます。

Cosmos DB

このソリューションでは、ソリューションに接続されているデバイスに関する情報を格納するために Cosmos DB データベースを使用します。 この情報には、ソリューション ポータルからデバイスに送信されたコマンドと、ソリューション ポータルから呼び出されたメソッドの履歴が含まれています。

ソリューション ポータル

ソリューション ポータルは、構成済みソリューションの一部としてデプロイされる Web アプリです。 ソリューション ポータルの主要ページは、ダッシュボードとデバイス一覧です。

ダッシュボード

Web アプリのこのページでは、デバイスから送信されたテレメトリ データを、PowerBI JavaScript コントロール (PowerBI-visuals リポジトリを参照) で視覚化します。 このソリューションは、ASA テレメトリ ジョブを使用して Blob Storage にテレメトリ データを書き込みます。

デバイス一覧

ソリューション ポータルのこのページでは、以下の操作を行うことができます。

• 新しいデバイスをプロビジョニングする。 このアクションによって一意のデバイス ID が設定され、認証キーが生成されます。 デバイスに関する情報は、IoT Hub の ID レジストリとソリューション固有の Cosmos DB データベースの両方に書き込まれます。
• デバイスのプロパティを管理する。 このアクションでは、既存のプロパティを表示したり、新しいプロパティで更新したりすることができます。
• デバイスにコマンドを送信する
• デバイスのコマンド履歴を表示する
• デバイスの有効と無効を切り替える。

次の手順

以下の TechNet ブログ投稿には、リモート監視の構成済みソリューションについての詳細情報が記載されています。

• IoT Suite - Under The Hood - Remote Monitoring (IoT スイート - 内部のしくみ - リモート監視)
• IoT Suite - Remote Monitoring - Adding Live and Simulated Devices (IoT スイート - リモート監視 - ライブおよびシミュレートされたデバイスの追加)

引き続き IoT Suite の概要について学習するには、次の記事を参照してください。

• デバイスをリモート監視の事前構成済みソリューションに接続する
• azureiotsuite.com サイトでのアクセス許可