LoginSignup
0
1

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 3 years have passed since last update.

@youtoy(Yosuke Toyota)inKDDI株式会社

Azure IoT Hub へのデータ送信と Azure Stream Analytics による可視化の下準備を試す（公式ドキュメントやサンプルをピックアップしつつ）

Last updated at Posted at 2021-10-31

公式ドキュメント等を見ながら、Azure IoT Hub を試していきます。
（参照した公式ドキュメント・サンプルの情報は、記事の中に記載していきます）

リソースの作成とデバイス登録

以下の公式ドキュメントの「IoT Hub の作成」・「IoT ハブに新しいデバイスを登録する」の項目の内容を進めていきます。

●Azure Portal を使用して IoT Hub を作成する | Microsoft Docs
　https://docs.microsoft.com/ja-jp/azure/iot-hub/iot-hub-create-through-portal

以下は、IoT Hub のリソース作成が完了した後です。

そして、デバイスの新規登録を行った後の画面です。
デバイスの新規登録の後

Node.js のサンプルを見ていく

公式のドキュメントやサンプルを見ていくと、以下のページがあり、その中に GitHub のリポジトリへのリンクが掲載されていました。

●Azure IoT Samples for Node.js - Code Samples | Microsoft Docs
　https://docs.microsoft.com/ja-jp/samples/azure-samples/azure-iot-samples-node/azure-iot-samples-for-nodejs/

送受信用のそれぞれのサンプル

受信側

受信側のプログラムについては、上記のリポジトリを見ていくと、以下のものが見つかりました。

●azure-iot-samples-node/receive_methods.js at master · Azure-Samples/azure-iot-samples-node
　https://github.com/Azure-Samples/azure-iot-samples-node/blob/master/iot-hub/Samples/device/receive_methods.js

// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

'use strict';

var Protocol = require('azure-iot-device-mqtt').Mqtt;
var Client = require('azure-iot-device').Client;

// String containing Hostname, Device Id & Device Key in the following formats:
//  "HostName=<iothub_host_name>;DeviceId=<device_id>;SharedAccessKey=<device_key>"
var connectionString = process.env.DEVICE_CONNECTION_STRING;
if (!connectionString) {
  console.log('Please set the DEVICE_CONNECTION_STRING environment variable.');
  process.exit(-1);
}

// fromConnectionString must specify a transport constructor, coming from any transport package.
var client = Client.fromConnectionString(connectionString, Protocol);

client.open(function (err) {
  if (err) {
    console.error(err.toString());
    process.exit(-1);
  } else {
    console.log('client successfully connected');
    client.on('error', function (err) {
      console.error(err.toString());
      process.exit(-1);
    });

    // register handler for 'methodName1'
    client.onDeviceMethod('methodName1', function (request, response) {
      console.log('received a request for methodName1');
      console.log(JSON.stringify(request.payload, null, 2));
      var fakeResponsePayload = {
        key: 'value'
      };

      response.send(200, fakeResponsePayload, function (err) {
        if (err) {
          console.error('Unable to send method response: ' + err.toString());
          process.exit(-1);
        } else {
          console.log('response to methodName1 sent.');
          process.exit(0);
        }
      });
    });

    // register handler for 'methodName2'
    client.onDeviceMethod('methodName2', function () {
      // ...
    });
  }
});

送信側

送信側の例としては、以下のものが見つかりました。

●azure-iot-samples-node/send_telemetry.js at master · Azure-Samples/azure-iot-samples-node
　https://github.com/Azure-Samples/azure-iot-samples-node/blob/master/iot-hub/Samples/device/send_telemetry.js

// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

'use strict';

var uuid = require('uuid');
var Protocol = require('azure-iot-device-mqtt').Mqtt;
// Uncomment one of these transports and then change it in fromConnectionString to test other transports
// var Protocol = require('azure-iot-device-amqp').AmqpWs;
// var Protocol = require('azure-iot-device-http').Http;
// var Protocol = require('azure-iot-device-amqp').Amqp;
// var Protocol = require('azure-iot-device-mqtt').MqttWs;
var Client = require('azure-iot-device').Client;
var Message = require('azure-iot-device').Message;

// String containing Hostname, Device Id & Device Key in the following formats:
//  "HostName=<iothub_host_name>;DeviceId=<device_id>;SharedAccessKey=<device_key>"
var connectionString = process.env.DEVICE_CONNECTION_STRING;
if (!connectionString) {
  console.log('Please set the DEVICE_CONNECTION_STRING environment variable.');
  process.exit(-1);
}

// fromConnectionString must specify a transport constructor, coming from any transport package.
var client = Client.fromConnectionString(connectionString, Protocol);

client.open(function (err) {
  if (err) {
    console.error('Could not connect: ' + err.message);
  } else {
    console.log('Client connected');

    client.on('error', function (err) {
      console.error(err.message);
      process.exit(-1);
    });

    // any type of data can be sent into a message: bytes, JSON...but the SDK will not take care of the serialization of objects.
    var message = new Message(JSON.stringify({
      key: 'value',
      theAnswer: 42
    }));
    // A message can have custom properties that are also encoded and can be used for routing
    message.properties.add('propertyName', 'propertyValue');

    // A unique identifier can be set to easily track the message in your application
    message.messageId = uuid.v4();

    console.log('Sending message: ' + message.getData());
    client.sendEvent(message, function (err) {
      if (err) {
        console.error('Could not send: ' + err.toString());
        process.exit(-1);
      } else {
        console.log('Message sent: ' + message.messageId);
        process.exit(0);
      }
    });
  }
});

その他のサンプル（クイックスタート）

さらにリポジトリ内を見ていくと、クイックスタートもありました。

●azure-iot-samples-node/iot-hub/Quickstarts at master · Azure-Samples/azure-iot-samples-node
　https://github.com/Azure-Samples/azure-iot-samples-node/tree/master/iot-hub/Quickstarts
クイックスタート.jpg

その中の 1つである「simulated-device」を見てみます。

●azure-iot-samples-node/iot-hub/Quickstarts/simulated-device at master · Azure-Samples/azure-iot-samples-node
　https://github.com/Azure-Samples/azure-iot-samples-node/tree/master/iot-hub/Quickstarts/simulated-device

その中には、以下のサンプルが置かれていました。

// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

'use strict';

// The device connection string to authenticate the device with your IoT hub.
//
// NOTE:
// For simplicity, this sample sets the connection string in code.
// In a production environment, the recommended approach is to use
// an environment variable to make it available to your application
// or use an HSM or an x509 certificate.
// https://docs.microsoft.com/azure/iot-hub/iot-hub-devguide-security
//
// Using the Azure CLI:
// az iot hub device-identity show-connection-string --hub-name {YourIoTHubName} --device-id MyNodeDevice --output table
var connectionString = '{Your device connection string here}';

// Using the Node.js Device SDK for IoT Hub:
//   https://github.com/Azure/azure-iot-sdk-node
// The sample connects to a device-specific MQTT endpoint on your IoT Hub.
var Mqtt = require('azure-iot-device-mqtt').Mqtt;
var DeviceClient = require('azure-iot-device').Client
var Message = require('azure-iot-device').Message;

var client = DeviceClient.fromConnectionString(connectionString, Mqtt);

// Create a message and send it to the IoT hub every second
setInterval(function(){
  // Simulate telemetry.
  var temperature = 20 + (Math.random() * 15);
  var message = new Message(JSON.stringify({
    temperature: temperature,
    humidity: 60 + (Math.random() * 20)
  }));

  // Add a custom application property to the message.
  // An IoT hub can filter on these properties without access to the message body.
  message.properties.add('temperatureAlert', (temperature > 30) ? 'true' : 'false');

  console.log('Sending message: ' + message.getData());

  // Send the message.
  client.sendEvent(message, function (err) {
    if (err) {
      console.error('send error: ' + err.toString());
    } else {
      console.log('message sent');
    }
  });
}, 1000);

Node.js のサンプルを試す

上で見てきたサンプルの一部を使って、実際に試していきます。

以下の部分に出てくる azure-iot-device-mqtt と azure-iot-device が必要そうなので、これを準備します。

var Mqtt = require('azure-iot-device-mqtt').Mqtt;
var DeviceClient = require('azure-iot-device').Client
var Message = require('azure-iot-device').Message;

npm i azure-iot-device-mqtt azure-iot-device を実行します。
そして、クイックスタートにあったプログラムの '{Your device connection string here}' の部分は Azureポータルで取得した、デバイスの接続文字列を記載します。

プログラムはサンプルほぼそのままです（コメントを削除したり var で宣言されている部分を少し変えたりした程度）。

"use strict";

const connectionString = '{Your device connection string here}';

const Mqtt = require("azure-iot-device-mqtt").Mqtt;
const DeviceClient = require("azure-iot-device").Client;
const Message = require("azure-iot-device").Message;

const client = DeviceClient.fromConnectionString(connectionString, Mqtt);

setInterval(function () {
  const temperature = 20 + Math.random() * 15;
  const message = new Message(
    JSON.stringify({
      temperature: temperature,
      humidity: 60 + Math.random() * 20,
    })
  );

  message.properties.add(
    "temperatureAlert",
    temperature > 30 ? "true" : "false"
  );

  console.log("Sending message: " + message.getData());

  client.sendEvent(message, function (err) {
    if (err) {
      console.error("send error: " + err.toString());
    } else {
      console.log("message sent");
    }
  });
}, 1000);

以下は実行結果です。

そして、Azureポータルの画面を見にいくと、何らかデータを受信できていそうな表示が確認できました。

他のデバイスシミュレータ

上記は、Node.js のプログラムがデバイスの代替となっていましたが、他に「Raspberry Pi Azure IoT Online Simulator」というものもあるようです。

データの可視化の下準備

まずは情報のチェック

Azure App Service を使うパターン

Azure IoT Hub にデータを送ることができたようなので、あとは可視化してみます。

公式ドキュメントを見ていくと、ちょうど以下の内容のものがありました。

●Web アプリでの IoT Hub データのリアルタイム データの視覚化 | Microsoft Docs
　https://docs.microsoft.com/ja-jp/azure/iot-hub/iot-hub-live-data-visualization-in-web-apps

関連するソースコードは、以下になるようです。

●Azure-Samples/web-apps-node-iot-hub-data-visualization: web application for visualization data from IoT Hub
　https://github.com/Azure-Samples/web-apps-node-iot-hub-data-visualization

上記の方法を使った話の記事として、以下があったりしました。

●Azure IoT Hubに送信したデータを可視化する（App Service編） - Qiita
　https://qiita.com/Yokogawa_Mita/items/e060d8413b65d8ebd166

Power BI を使うパターン

可視化の方法として、他に以下のようなやり方もありました。

●Azure IoT Hub から取得したデータのリアルタイム データの視覚化 – Power BI | Microsoft Docs
　https://docs.microsoft.com/ja-jp/azure/iot-hub/iot-hub-live-data-visualization-in-power-bi

上記の方法を使った話の記事として、以下があったりしました。

●Azure IoT Hubに送信したデータを可視化する（Power BI編） - Qiita
　https://qiita.com/Yokogawa_Mita/items/13c0fcf92c4802473d02

Azure Stream Analytics と連携させる

上記の公式ドキュメントのほうを見ながら準備を進めていきます。

ドキュメント中の以下を試しました。

  • Azure IoT Hub関連
    • IoT Hub へのコンシューマー グループの追加
  • Azure Stream Analytics関連
    • Stream Analytics のジョブの作成
    • Stream Analytics ジョブへの入力の追加

この後、 Stream Analytics ジョブへの出力の追加などをやっていく必要があるのですが、内容が長くなったので、いったんここまでで区切ろうと思います。

ちなみに、出力先として Power BI以外にも、以下のものが選べるようです。
出力の種類
関連する公式ドキュメントは以下になるようです。

●Azure Stream Analytics からの出力 | Microsoft Docs
　https://docs.microsoft.com/ja-jp/azure/stream-analytics/stream-analytics-define-outputs

おわりに

Node.js のプログラムを使った Azure IoT Hub へのデータ送信と、Azure Stream Analytics との連携を試していきました。
Azure Stream Analytics は可視化のための下準備で、Power BI との連携を試そうと思っていたりしますが、Azure Stream Analytics とつなげられる他の出力先で何か進めやすそうなものがあれば、それを試せればと思います。

0
1
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
0
1

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?