Tag: azure iot hub

使用nodejs将数据从Rfid rc522发送到azureiot集线器

//THIS IS THE CODE TO READ SERIAL NUMBER AND SEND DATA TO AZURE IOT HUB var rc522=require("rc522/build/Release/rc522"); var Async = require('async'); var Protocol = require('azure-iot-device-http').Http; var Client = require('azure-iot-device').Client; var ConnectionString = require('azure-iot-device').ConnectionString; var Message = require('azure-iot-device').Message; // Enter Device Connection String: AZURE–> IOTHub –> Devices–> select Device–> Connection String. var connectionString = ''; var […]

TypeError:client.getReceiver不是azure-iot-device-http示例中的函数

我正在使用azure-iot-device-http ,并运行入门代码: var clientFromConnectionString = require('azure-iot-device-http').clientFromConnectionString; var Message = require('azure-iot-device').Message; var connectionString = 'myHostname,myDevice,myKey; var client = clientFromConnectionString(connectionString); var msg = new Message('some data from my device'); client.sendEvent(msg, function (err) { if (err) console.log(err.toString()); }); client.getReceiver(function (err, rcv) { rcv.on('message', function (msg) { console.log(msg); rcv.complete(msg, function () { console.log('completed'); }); }); rcv.on('errorReceived', function (err) { […]

如何检查Azure IOT Hub发件人是否已停止使用node.js和socket.io

我有两个程序,一个发件人和一个接收者。 发送者在IOT Hub上发送一些消息给设备,接收者只要发送者发送它们就会接收到这些消息。 我正在使用socket.io将这些消息广播到连接的客户端。 但是,当发送者停止时,接收者也会停下来,但发送者发送的最后一条消息会无限播放,直到我closures接收者或者发送者再次启动并发送新的消息。 最后一条消息将被复制并无限播放。 如何检查发件人程序是否已经停止? 这是发件人的程序: var clientFromConnectionString = require('azure-iot-device-mqtt').clientFromConnectionString; var Message = require('azure-iot-device').Message; var connectionString = 'conn_string' var client = clientFromConnectionString(connectionString); var avgTemperature = 20; var printResult = function (err, res) { if (err) { console.log('send error: ' + err.toString()); return; } console.log('send status: ' + res.constructor.name); }; setInterval(function () { var […]