Azure Durable Functions：Activity返回值无法传递至Orchestrator问题排查

问题根源 #

你遇到的核心问题是AirWatchToken Activity函数没有正确返回异步API调用的结果：

• 如果Activity里用了异步操作（比如fetch、axios）但没正确处理Promise，函数会提前返回undefined/null，或者返回Promise的内部状态标识（比如你看到的1，可能是Promise的pending状态码）。
• 即便console.log能打印正确结果，但如果没把这个结果通过return传递给函数外部，Orchestrator就拿不到有效值。

修复方案 #

1. 修正Activity函数的异步处理逻辑 #

错误示例（导致返回null/1）：

module.exports = async function(context) {
  // 错误：没有await异步请求，函数直接返回undefined
  fetch('https://your-airwatch-api/token', { method: 'POST' })
    .then(res => res.json())
    .then(data => {
      console.log(data.access_token);
      // 这里的return只在then回调内部生效，不会传递给Activity函数
    });
};

正确写法1（用await）：

module.exports = async function(context) {
  try {
    const response = await fetch('https://your-airwatch-api/token', {
      method: 'POST',
      headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
      body: 'grant_type=client_credentials&client_id=xxx&client_secret=xxx'
    });
    
    if (!response.ok) {
      throw new Error(`API请求失败：${response.status}`);
    }
    
    const data = await response.json();
    console.log(data.access_token);
    // 必须return结果，Orchestrator才能拿到
    return data.access_token;
  } catch (err) {
    context.log.error('获取AirWatch Token失败:', err);
    throw err; // 抛出错误让Orchestrator处理失败流程
  }
};

正确写法2（用Promise链式调用，需return整个链）：

module.exports = function(context) {
  // 必须return整个Promise链，让Durable Functions等待异步操作完成
  return fetch('https://your-airwatch-api/token', { method: 'POST' })
    .then(res => {
      if (!res.ok) throw new Error(`HTTP错误：${res.status}`);
      return res.json();
    })
    .then(data => {
      console.log(data.access_token);
      return data.access_token;
    })
    .catch(err => {
      context.log.error('Token获取失败:', err);
      throw err;
    });
};

2. 确保Orchestrator正确等待Activity结果 #

Orchestrator中必须用yield（或await，取决于Durable Functions版本）获取Activity的返回值：

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
  try {
    // 用yield等待Activity完成并获取结果
    const resultToken = yield context.df.callActivity("AirWatchToken");
    context.log("成功获取Token:", resultToken);
    // 后续业务逻辑
    return resultToken;
  } catch (err) {
    context.log.error("Orchestrator处理失败:", err);
    throw err;
  }
});

额外注意事项 #

• Activity返回的结果必须是可JSON序列化的值（字符串、普通对象等），不能返回函数、Symbol等不可序列化类型。
• 一定要处理API调用的异常情况，避免未捕获的Promise拒绝导致返回值异常。
• 检查Azure Function的日志，确认Activity是否有未上报的错误。

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