#1.はじめに
本記事では，Microsoft Azureで提供するIoT サービスを利用してデバイスの情報をデータベースに保存する手順を備忘録として記載している。
※2019/09/01時点での情報に基づいた記事となる。
#2.アーキテクチャ
本記事では、下記図のように、IoT HubとCosmos DBをStream Analyticsでつなぐ簡単な構成となっている。
今回は、デバイスを用意していないので、プログラムで実装した温度・湿度情報を送信する仮想的なデバイスを利用してクラウドに保存する。
【リソース選択理由】
①IoT Hub：IoT Hub はデバイスからデータを受信，デバイスの管理およびデバイスへの情報の送信ができることため，今回はIoT Hubを選択する
②Cosmos DB：色々なDBがあるが、今回はとりあえずCosmos DBをつかってみる
③Stream Analytics：二つのリソースをつなぐ機能があったので、Stream Analyticsを選択
#3.IoT Hubの作成と設定
本章では、主にこちらのチュートリアルを参照しながら、IoT Hubを作成した。
※Pythonを使ったことがあるので、Pythonを選択。（他の言語も利用可）
##IoT Hub作成
Azure Portalにログインし、IoT Hubを作成した。
【IoT Hub作成①】
【IoT Hub作成②】
###各種設定項目(こちら参照)
①IoT Hub のスケールティアの選択
サイズ・価格についてはこちら
※1メッセージ= 4KBの情報
②ユニット数
トラフィックは、ハブ単位ではなく、ユニット単位で測定されます。レベル1または2のIoT Hubインスタンスには、最大で 200 個のユニットを関連付けることができます。レベル3のIoT Hubインスタンスは、最大で 10 個のユニットを持つことができます。リンク
③Device to cloud パーティション
IoT Hubの中のEvent Hubパーティション数
※パーティションとは，Hubがデータを格納できるキューの数
【補足リンク】
ソリューションに適した IoT Hub のレベルを選択する
##IoT Hubの設定
###デバイスの登録
デバイスとクラウドを接続するために、作成したIoT Hubの 「IoTデバイス＞新規作成」 でIoT Hubと接続するデバイスを登録する。（1デバイスずつ登録する）
【デバイス登録①】
【デバイス登録②】
※プライマリ接続文字列を後ほどデバイスをクラウドと接続するために利用する
##IoT Hubにテストデータを送信してみる
###IoT Hub が受信したデータをモニタリングするためのDevice Explorerの準備
下記のようにDevice ExplorerとIoT Hubを接続する。
1.接続文字列（主キー）を'IoT Hub Connection String'に入力
※作成したIoT Hubの共有アクセスポリシーより取得
2.'Update'をクリック
###デバイスからIoT Hub にデータを送信
今回チュートリアルにあるサンプルコード（こちら）を利用して仮想的なデバイスからIoT Hubにデータを送信してみた。
※プログラムは"azure-iot-samples-python-master\azure-iot-samples-python-master\iot-hub\Quickstarts\simulated-device\SimulatedDevice.py"を利用する。
サンプルコードの{Your IoT Hub device connection string}を作成したIoT Hubの接続文字列を貼り付ける。（IoT Hubからみてデバイスとの接続のため、デバイス登録した時に取得したプライマリー接続文字列を利用する）
# az iot hub device-identity show-connection-string --hub-name {YourIoTHubName} --device-id MyNodeDevice --output table
CONNECTION_STRING = "{Your IoT hub device connection string}"
Device ExplorerのDataタブの「Monitor」をクリックし、モニタリングを開始。
サンプルコードを実行すると、下記のように結果が出た。
【実行画面】
【Device Explorer(IoT Hub側)】
実行画面のデータとDevice Explorerで表示されているデータが一致するため、デバイスから送った情報が正しくIoT Hubに送信されていることが確認できた。
#4.Cosmos DBの作成
###Cosmos DB のリソース作成
IoT Hub で受信したデータを保存するためのデータベースを作成する。
※マルチリージョン書き込み：他リージョンへレプリケーションを行った際に他リージョンからも書き込みが可能なようにする設定。無効にすると，上記例では東日本リージョンのリソースからしか書き込みできない。
価格について：こちら
###Cosmos DB のデータベースとコンテナ作成
受け取ったデータを保存するためのコンテナを作成する
Partition key の設定は，送信されるデータの一番最初のキーを設定し、今回は"temperature"とする
ここが送信されるデータの先頭のキーと一致しない場合はエラーが発生する
【Cosmos DBコンテナ作成画面】
【作成後のデータエクスプローラーの画面】
#5.Azure Stream Analyticsの作成と設定
ここでは、IoT Hubで受け取ったデータをCosmos DBに保存するためのリソース、Stream Analyticsを作成・設定する
##Stream Analyticsの作成
Azure Portalより、Stream Analyticsを作成する。
【Stream Analytics作成画面】
ストリーミングユニットごとに課金が1時間単位で発生するので注意（後から変更可）
課金はこちらを確認
##Stream Analyticsの設定
Stream Analyticsへの入力と出力のリソースと入出力間で適用するクエリをそれぞれ設定する。
###入力
入力＞ストリーム追加＞IoT Hubより設定
※コンシューマグループとは，IoT Hubでのデータの出口のグループのことを指す
###出力
出力＞ストリーム追加より設定
※コンテナ名パターンはデータを保存するCosmos DBのコンテナ名を指す
###クエリの設定
今回は、デフォルトのクエリのまま、受信した情報をそのまま出力するようにクエリを記載。下記のように入力と出力の名前を書き換える。
【クエリ設定画面】
全ての設定が終了したら、開始ボタンを押す
【注意】Stream Analyticsは入力と出力の設定が終わった後に開始をしないと，エラーが発生します。開始後に入力・出力リソースの設定変更を実施すると、エラーが発生します。
#6.デバイスからデータを送信し、Cosmos DBに保存されていることを確認
IoT Hubにデータを送信した時と同じプログラム(SimulatedDevice.py)を実行して、IoT HubおよびCosmos DBでデータが受信しているかを確認した。
【実行画面】
【Device Explorer(IoT Hub側)】
【Cosmos DB】
上記の3つの結果より、temperatureの値が全ての結果で一致しているため、Cosmos DBにデータが保存されてことを確認できる。
#参考情報
https://docs.microsoft.com/ja-jp/azure/iot-hub/quickstart-send-telemetry-python