Azure Durable Functions中MongoDB连接回调内代码无响应问题排查

Durable Functions的Orchestrator函数是确定性的工作流引擎，它依赖于generator函数的yield关键字来严格控制异步流程的执行顺序。你遇到的问题核心在于：你在Orchestrator里使用了回调式的异步操作（mongoClient.connect的回调函数），这种操作会完全脱离Orchestrator的执行上下文，导致回调内的代码永远不会被正确执行。

当Orchestrator执行到mongoClient.connect时，它会立即跳过回调逻辑，继续执行后面的代码（比如context.log(timeSched.length)，所以你会看到输出0），而不会等待回调触发。等回调函数终于触发时，Orchestrator已经完成了当前的执行轮次，上下文已经失效，所以你看不到任何回调内的日志，也无法获取到数据库里的时间数据。

MongoDB客户端已经原生支持Promise，我们可以把回调式的操作改成Promise形式，然后用yield等待操作完成，这样Orchestrator会暂停执行直到数据获取完成，再继续后续的定时器和活动函数调用逻辑。

修复后的代码如下：

const df = require("durable-functions");
const moment = require("moment");
const mongoClient = require("mongodb").MongoClient;

module.exports = df.orchestrator(function*(context) {
    context.log("Getting time schedules in DB");
    let timeSched = [];
    const dbName = "<dbName>";
    const collectionName = "<collectionName>";
    const query = {id: "1"};
    
    try{
        // 1. 改用Promise形式连接MongoDB，并用yield等待连接完成
        const client = yield mongoClient.connect(
            "<mongoDB_connection_string>",
            {useNewUrlParser: true, authSource: dbName}
        );
        context.log('MongoClient connected to DB');

        // 2. 同样用Promise形式查询数据，yield等待结果返回
        const collection = client.db(dbName).collection(collectionName);
        const result = yield collection.find(query).toArray();
        
        // 3. 处理获取到的时间数据
        for(let i = 0; i < result.length; i++){
            timeSched.push(result[i].time); //e.g.8:00
        }
        client.close();
        context.log(timeSched); // 现在会正确打印时间数组
        
        // 4. 处理定时器和活动函数调用
        for (let j = 0; j < timeSched.length; j++) {
            const deadline = moment.utc(context.df.currentUtcDateTime).add(3, 'minutes');
            yield context.df.createTimer(deadline.toDate());
            yield context.df.callActivity("ActivityFunction", timeSched[j]);
        }
    }catch(e){
        context.log(`Error ${e}`);
        // 抛出错误让Durable Functions自动处理失败流程
        throw e;
    }
});

• 永远不要在Orchestrator里用回调：Orchestrator必须通过yield等待所有异步操作，确保工作流的确定性和可重放性。任何脱离yield的异步操作（比如回调、setTimeout）都会导致不可预测的行为。
• 移除context.done()：在Durable Functions Orchestrator里不需要手动调用context.done()，函数执行完成或抛出错误时会自动处理工作流的结束。
• 优先使用原生Promise支持：大多数现代数据库客户端都支持Promise，尽量使用这种方式来适配Orchestrator的执行模型。

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