外部DBにIOTハブメッセージを送信

Question

IoTハブソリューションは2つのデバイスからのメッセージを受け取ります.24時間後にIoTハブデータが削除されるため、そのデータをMongoDBに保存する必要があります。 ノードJSにイベントハブ関数を書きましたが、それも機能しますが、データがDBに表示されることはありません。

module.exports = function(context, mySbMsg) { 
context.log('Message received: '+ JSON.stringify(iotHubMessage)); 
var MongoClient = require('mongodb').MongoClient; 
var url = 'mongodb:/abc.abc.abc.abc:27017/XYZ'; 
MongoClient.connect(url, function(err, db) { 
if (err) throw err; 
console.log("Database connected!"); 
db.collection("IoTData").insertOne(mySbMsg, function(err, res) { 
if (err) throw err; 
console.log("1 document inserted"); 
db.close(); });}); 
context.done();}; 

Answer 1

次のコードをテストしました。機能アプリをテストすると、ログを追跡できます。

module.exports = function (context, IoTHubMessages) { 
    context.log('Message received:' + IoTHubMessages); 

    var MongoClient = require('mongodb').MongoClient; 

    var url = '{{Your mongoDb connection string}}'; 
    MongoClient.connect(url, function(err, db) { 

      if (err) throw err; 

      context.log("Database connected!"); 

      db.collection("IoTData").insertOne({IoTHubMessages:IoTHubMessages}, function(err, res) { 
        if (err) throw err; 

        context.log("1 document inserted"); 
       }); 
      db.close(); 
     } 
    ); 

    context.done(); 
};