Azure Functions(NodeJS)无法将IoT Hub数据插入CosmosDB问题排查

我一眼就看出问题所在了——你的函数提前终止了，导致MongoDB连接的异步回调根本没机会执行！

问题根源分析 #

看你的日志，Done called在MongoClient created之后立刻就出现了，这说明你在mongoClient.connect这个异步操作完成之前，就调用了context.done()，直接告诉Azure Function：“我执行完了，可以结束了”。

而MongoDB的连接是异步操作，需要时间建立网络连接、验证权限。当函数进程被提前终止后，后续的连接回调、数据插入逻辑都被直接跳过了，所以你看不到任何数据库相关的日志，数据也根本没存进去。

再看代码里的具体错误：

• 你在try块的最后（mongoClient.connect调用之后）和catch块之后都调用了context.done()，这两个调用都会在异步连接完成前执行，直接终止函数
• 另外，collection.insertOne也是异步操作，你现在没有处理它的回调，就算连接成功了，插入操作也可能在函数终止前没完成

修复后的代码（回调版本） #

module.exports = function (context, IoTHubMessage) {
    try {
        var dbName = "db";
        var collectionName = "encodedmessages";
        context.log(`JavaScript eventhub trigger function called for message array: ${IoTHubMessage}`);
        
        var mongoClient = require("mongodb").MongoClient;
        context.log('MongoClient created');
        
        // 异步连接数据库
        mongoClient.connect("mongodb://xxx:password==@xxx.mongo.cosmos.azure.com:10255/?ssl=true&replicaSet=globaldb&retrywrites=false&maxIdleTimeMS=120000&appName=@db@", 
            {useNewUrlParser: true, authSource: dbName}, 
            function (err, client) {
                if(err){
                    context.log(`Error occurred while connecting to DB ${err}`);
                    // 连接失败，传递错误并结束函数
                    context.done(err);
                    return;
                }
                
                context.log('MongoClient connected to DB');
                var collection = client.db(dbName).collection(collectionName);
                context.log('MongoClient collection retrieved');
                
                // 异步插入数据，处理回调
                collection.insertOne(IoTHubMessage, {w: 1}, function(insertErr) {
                    if(insertErr) {
                        context.log(`Error inserting message: ${insertErr}`);
                        client.close();
                        context.done(insertErr);
                        return;
                    }
                    
                    context.log(`Saved message: ${IoTHubMessage}`);
                    client.close();
                    // 所有操作完成，结束函数
                    context.done();
                });
            }
        );
    } catch (e){
        context.log(`Error ${e}`);
        context.done(e);
    }
};

关键修改点：

1. 把所有context.done()的调用都移到异步操作的回调内部，确保只有当所有异步逻辑完成后，函数才会终止
2. 处理了insertOne的回调，确保插入操作完成后再结束函数
3. 使用connect回调返回的client实例来操作数据库，这是MongoDB官方推荐的规范用法

更优雅的async/await版本（推荐） #

用async/await替代嵌套回调，代码结构更扁平，可读性更强：

const { MongoClient } = require("mongodb");

module.exports = async function (context, IoTHubMessage) {
    try {
        const dbName = "db";
        const collectionName = "encodedmessages";
        context.log(`JavaScript eventhub trigger function called for message array: ${IoTHubMessage}`);
        
        // 等待连接完成
        const client = await MongoClient.connect(
            "mongodb://xxx:password==@xxx.mongo.cosmos.azure.com:10255/?ssl=true&replicaSet=globaldb&retrywrites=false&maxIdleTimeMS=120000&appName=@db@",
            { useNewUrlParser: true, authSource: dbName }
        );
        
        context.log('MongoClient connected to DB');
        const collection = client.db(dbName).collection(collectionName);
        context.log('MongoClient collection retrieved');
        
        // 等待插入完成
        await collection.insertOne(IoTHubMessage, {w: 1});
        context.log(`Saved message: ${IoTHubMessage}`);
        
        client.close();
        context.done();
    } catch (e){
        context.log(`Error ${e}`);
        context.done(e);
    }
};

额外注意事项 #

1. 不要硬编码连接字符串：把连接字符串存储在Function的应用设置中（比如MongoDBConnectionString），然后通过process.env.MongoDBConnectionString读取，更安全也更易维护
2. 网络权限验证：确保你的Azure Function所在的网络可以访问Cosmos DB（比如在Cosmos DB的防火墙设置中允许Azure服务访问）
3. 连接池优化：对于高并发场景，建议使用MongoDB的连接池，避免每次函数调用都创建新连接，提升性能

内容的提问来源于stack exchange，提问作者Luis Valencia