azure-iot-digitaltwins-device

Azure IoT Digital Twins Device SDK

PREVIEW - WILL LIKELY HAVE BREAKING CHANGES

Features

Use the Azure IoT Digital Twins Device SDK to:

• Register multiple interfaces that a device implements.
• Send Telemetry data to Azure IoT Hub.
• Report property changes to Azure IoT Hub.
• Receive changes to writable properties.
• Handle synchronous and asynchronous commands from IoTHub.

Prerequisites

You need to install the Node.js JavaScript runtime environment to run the Azure IoT JavaScript client SDK on your platform. To check if Node.js supports your platform (OS), verify that an install package is available on the Node.js download page.

npm is a command-line package manager that is installed with Node.js is installed, and will be used to install Azure IoT node.js client side SDK.

Installation

To get the latest version you need to install this package as well as the device client and the MQTT transport that support the digital twin client:

npm install azure-iot-digitaltwins-device@pnp-preview
npm install azure-iot-device@pnp-preview
npm install azure-iot-device-mqtt@pnp-preview

Getting started

You can use the code below to send telemetry to IoT Hub.

Note that for this sample to work, you will need to setup your IoT hub and provision your device and get its credentials. In the code, replace '[IoT Hub device connection string]' with the device credentials created in the IoT Hub.

const DigitalTwinClient = require('azure-iot-digitaltwins-device').DigitalTwinClient;
const DeviceClient = require('azure-iot-device').Client;
const Mqtt = require('azure-iot-device-mqtt').Mqtt;

const EnvironmentalSensor = require('./environmentalinterface').EnvironmentalSensor;

const propertyUpdateHandler = (interfaceInstance, propertyName, reportedValue, desiredValue, version) => {
  console.log('Received an update for ' + propertyName + ': ' + JSON.stringify(desiredValue));
  interfaceInstance[propertyName].report(desiredValue, {
    code: 200,
    description: 'helpful descriptive text',
    version: version
  })
    .then(() => console.log('updated the property'))
    .catch(() => console.log('failed to update the property'));
};

const commandHandler = (request, response) => {
  console.log('received command: ' + request.commandName + ' for interfaceInstance: ' + request.interfaceInstanceName);
  response.acknowledge(200, 'helpful response text')
    .then(() => console.log('acknowledgement succeeded.'))
    .catch(() => console.log('acknowledgement failed'));
};

const environmentalSensor = new EnvironmentalSensor('environmentalSensor', propertyUpdateHandler, commandHandler);

const deviceClient = DeviceClient.fromConnectionString(process.argv[2], Mqtt);

const capabilityModel = 'urn:azureiot:samplemodel:1';

async function main() {
  const digitalTwinClient = new DigitalTwinClient(capabilityModel, deviceClient);
  digitalTwinClient.addInterfaceInstance(environmentalSensor);
  await digitalTwinClient.register();
  await environmentalSensor.temp.send(65.5);
  await environmentalSensor.humid.send(12.2);
  console.log('Done sending telemetry.');
};

main();

Read More

• Azure IoT Hub dev center
• Azure IoT Hub documentation
• API reference