ステークカジノ 200 ボーナス Azure Cosmos DBのリソースを作成します。
ステークカジノ 200 ボーナス CallbackとAzure IoT Hub連携
2018.10.10
ステークカジノ 200 ボーナス Callbackには、Custom Callback以外にAWS IoT、AWS Kinesis、Microsoft Azure Event hub、Microsoft Azure IoT hub、IBM Watson IoT Platformへの連携が用意されています。
ここでは、Azure ステークカジノ 200 ボーナスT Hubとの連携方法を記載します。
ステークカジノ 200 ボーナス Callback設定とAzure IoT Hubの設定
まずは、AzureのWebコンソールから、Azure IoT Hubのリソースを作成します。ここでは、リソースグループ「ステークカジノ 200 ボーナスJapanKCCS」、IoT Hub名を「ステークカジノ 200 ボーナスIoT」として作成します。
作成されたステークカジノ 200 ボーナスIoTを選択し、左メニューからShared access policiesを選択、iothubownerを選択すると、Shared access keys情報が表示されますので、Connection String（下図赤枠のところをコピーしておきます）
次に、ステークカジノ 200 ボーナスクラウドで、Callback設定画面に移動し、「Microsoft Azure IoT hub」を選択します。
その後、下図のCallback編集画面が表示されるので、Connectステークカジノ 200 ボーナスn stringの入力テキストボックスに先ほどコピーしたAzure ステークカジノ 200 ボーナスT HubのConnectステークカジノ 200 ボーナスn Stringを貼り付けます。
あとは、Azure ステークカジノ 200 ボーナスT Hub側に送りたいJSONを記載します。今回は、下記のようなJSONを送ります。
{ "device" : "{device}", "data" : "{data}", "time" : {time}, "seqNumber" : {seqNumber} }
これで、連携完了です。
Azure ステークカジノ 200 ボーナスT Hubに戻り、Explorersのステークカジノ 200 ボーナスT devicesを選択すると、下図のようにCallbackされたデバイスIDが表示されていきます。
Stream Analytics JobによりDBにデータを保存する
今回は、Cosmos DBにステークカジノ 200 ボーナスのデバイスメッセージを保存していくので、Azure Cosmos DBのリソースを作成します。
Azure ステークカジノ 200 ボーナスsmos DBの作成
Azure Cosmos DBの作成画面は下図の通りです。Account Nameは適当（今回は「ステークカジノ 200 ボーナスcosmos」）APIは「SQL」として作成してみます。
[Create]ボタンを押すと作成がはじまります。
Stream Analytics Jobの作成
Stream Analytics Jobは、ステークカジノ 200 ボーナスT Hubから、今回のケースではCosmos DBにデータを移す役割になります。
今まで同様、リソースの作成で、Stream Analytics Jobを選択すると、下図のような画面になります。
ここで、Job nameは適当（今回は「ステークカジノ 200 ボーナスStreamJob」）に設定して、[作成]ボタンをクリックすると作成されます。（ごめんなさい。下記画像はStringJobになっていますが。。。）
作成後の設定項目ですが、基本的にはInput、Output、Queryを設定することにより、どこから、どこへ、どのようにデータを受け渡すかの設定が完了します。
Input
Inputは、左メニューのInputsを選択し、[+Add stream Input]から[ステークカジノ 200 ボーナスT Hub]を選択してください。
下図の設定画面になりますので、Input aliasの入力（今回は"InputFromステークカジノ 200 ボーナスTHub"にしました）、ステークカジノ 200 ボーナスT Hub名の選択、ステークカジノ 200 ボーナスT Hubから受け入れるデータのフォーマット（今回はJSON）等を選択します。
Output
Outputも、左メニューのOutputsを選択し、[+Add]から[ステークカジノ 200 ボーナスsmos DB]を選択してください。
下図の設定画面になりますので、Output aliasの入力（今回は"OutputToCosmosDB"にしました）、Output先のCosmos DB情報を入力します。DatabaseやCollectステークカジノ 200 ボーナスnは、先のCosmos DB作成の時に適当に作っておいてください。（新規作成でもできそうですが）
Query
最後に、InputからOutputへ受け渡すQueryを設定します。
Queryも、左メニューのQueryを選択します。実際のQuery文は、Output先にどのようなデータを渡したいかによりますが、とりあえず全部ということであれば、下記のようなクエリで出来ると思います。
SELECT
*
INTO
[OutputToCosmosDB] <- output="" alias="" from="" inputfromステークカジノ 200 ボーナスthub="" -="" input="" pre=""
設定したQueryを[Save]後、Stream Analytics Jobを開始するとデータの受け渡しが始まります。
ステークカジノ 200 ボーナスsmos DBでデータの確認
念のため、Cosmos DBのData Explorerから、DatabaseとCollectステークカジノ 200 ボーナスnを選択すると、格納されたデータを確認することができます。
おまけ
Stream Analytics Jobには、Functステークカジノ 200 ボーナスnsという機能があります。これは、InputデータをJavascript言語で加工することができます。
例えば、加速度計のX,Y,Zの値を元に加速度の値ACCをACC=√(X2+Y2+Z2)という式で求めて、その結果をDBに保存したい場合などに使えます。
Javascript UDFをAddし、下記のような関数を定義すれば
functステークカジノ 200 ボーナスn acc(x, y, z) {
return Math.pow((Math.pow(x, 2) + Math.pow(y, 2) + Math.pow(z, 2)), 0.5);
}
先程のQuery文で、下記のようにacc関数を呼び出すことができます。
SELECT
*,
udf.acc(x,y,z)
INTO
[OutputToCosmosDB] <- output="" alias="" from="" inputfromステークカジノ 200 ボーナスthub="" -="" input="" pre=""
お試しください。
著者情報
