发送消息时来自Azure IoT Hub Libary的错误

2 回答

• 1

  Azure IoT Hub是Azure上的预览功能服务 . 而针对Node.js的Azure IoT设备SDK正在快速发展 .

  我试图让熟悉这个主题的人参与进一步研究这个问题 . 可能会有一些时间延迟 .

  感谢您的耐心等待 .

  回复于 2024-05-17T10:07:13+08:00
• 0

  对于此问题，我建议您可以使用AMQPWS或HTTP传输来发送和接收消息 . 请参考我的步骤来实现发送和接收消息：

  首先，我们应该创建一个设备并获取设备ID和SAS . 在Azure新门户上创建了IOT中心后，我在node.js命令行上运行了这些命令：在新门户上创建IOT中心 .

  npm install -g iothub-explorer
  iothub-explorer HostName=****.azure-devices.net;SharedAccessKeyName=iothubowner;SharedAccessKey=****/****= create mydevice --connection-string
  

  我得到的结果如下：

  Created device mydevice
  
  -
    deviceId:                   mydevice
    generationId:               635881160181557968
    etag:                       MA==
    connectionState:            Disconnected
    status:                     enabled
    statusReason:               null
    connectionStateUpdatedTime: 0001-01-01T00:00:00
    statusUpdatedTime:          0001-01-01T00:00:00
    lastActivityTime:           0001-01-01T00:00:00
    cloudToDeviceMessageCount:  0
    authentication:
      SymmetricKey:
        primaryKey:   ****/****=
        secondaryKey: ****/****=
  -
    connectionString: HostName=****.azure-devices.net;DeviceId=mydevice;SharedAccessKey=****/****=
  

  其次，我在node.js项目上安装了SDK，文件夹结构与此图片相同：
  

  第三，我在我的项目上运行此代码：

  var device = require('azure-iot-device');
  var connectionString = 'HostName=****.azure-devices.net;DeviceId=mydevice;SharedAccessKey=****/****=';
  var client = device.Client.fromConnectionString(connectionString,device.AmqpWS);
  setInterval(function () {
      var windSpeed = 10 + (Math.random() * 4); // range: [10, 14] 
      var data = JSON.stringify({ deviceId: 'mydevice', windSpeed: windSpeed });
      var message = new device.Message(data);
      message.properties.add('myproperty', 'myvalue');
      console.log("Sending message: " + message.getData());
      client.sendEvent(message, printResultFor('send'));   
  }, 1000);
  
  client.getReceiver(function (err, receiver) {
      receiver.on('message', function (msg) {
          console.log('Id: ' + msg.properties.messageId + ' Body: ' + msg.body);
          receiver.complete(msg, function () {
              console.log('completed');
  
  
               // receiver.reject(msg, function() { 
               //   console.log('rejected'); 
               // }); 
               // receiver.abandon(msg, function() { 
               //   console.log('abandoned'); 
               // }); 
  
          });
          receiver.on('errorReceived', function (err) {
              console.warn(err);
  
          });
      });
  });
  
  function printResultFor(op) {
      return function printResult(err, res) {
          if (err) console.log(op + ' error: ' + err.toString());
          if (res) console.log(op + ' status: ' + res);
  
      };
  
  }
  

  它工作正常 . 此外，如果您使用“Http”传输，它也可以正常工作 . 您需要使用以下代码：

  var client = device.Client.fromConnectionString(connectionString);
  

  这就是我建议你使用AMQPWS的原因，因为这个代码在 "azure-iot-device\node_modules\azure-iot-common\node_modules\amqp10-transport-ws": 中

  if (this.uri.startsWith('wss')) {
      var wsTransport = require('amqp10-transport-ws');
      wsTransport.register(amqp10.TransportProvider);
    }
  

  如果URI的格式为'wss'，则它将注册AMQP传输 . 但AMQP传输的格式类似于“amqp：//” . 希望这可以帮助 .

  回复于 2024-05-17T10:07:13+08:00