使用 nodejs 将数据从 Rfid rc522 发送到 azure iot hub

Question

//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 deviceId = ConnectionString.parse(connectionString).DeviceId;
var client = Client.fromConnectionString(connectionString, Protocol);
var connectCallback=function(err){
if(err){
console.error('could not open connection' +err);

}
else{
console.log('client connected');
rc522(function(serial){
console.log(serial);
});
var readings = { Id:serial};
       
var message = new Message(JSON.stringify(readings));
client.sendEvent(message, function (error) {
                            if (error)
                            {
                                console.log(error.toString());
                            } 
                            else
                            {
                                console.log("Data sent on %s...", new Date());
				
                            }
                        });

}
}
client.open(connectCallback);

我无法使用 Nodejs 将 rfid rc522 序列号发送到 Azure IOT 集线器。我能够连接到客户端并在控制台上显示序列号，但在 azure iot 集线器中看不到任何接收到的消息。我编写了函数应用程序并将 iothub 消息发送到表存储。

下面是我的代码和输出

iothub and table storage output,

console output for rfid nodejs,

谁能解释一下如何将序列号发送到 azure IOT hub。 我已经搜索了有关此的资源，但在 nodejs 中找不到任何资源。

提前致谢

Answer 1

当您将JSON.stringify(readings) 登录到控制台时会发生什么？我不是 node.js 专家，但我认为 serial 在那里未定义，因为它在定义的 rc522(function(serial){ ..} 范围之外使用

试试

rc522(function(serial){
    console.log(serial);

    var readings = { Id:serial};
    var message = new Message(JSON.stringify(readings));
    client.sendEvent(message, function (error) {
       // code here
    });
});