Azure JavaScript队列触发器使用绑定输出队列失败排查

我正在实现一个Azure队列触发器，流程如下：通过队列接收PDF的URL，将PDF转换为PNG后上传至Azure Blob Storage，再把该Blob的新URL添加到另一个队列里。我不想用Azure Storage SDK，希望通过绑定来实现所有操作。

以下是我的配置和代码：

function.json 配置 #

{
  "bindings": [{
    "name": "pdffaxqueue",
    "type": "queueTrigger",
    "direction": "in",
    "queueName": "pdffaxqueue",
    "connection": "AzureWebJobsStorage"
  }, {
    "type": "queue",
    "direction": "out",
    "name": "myQueueItemii",
    "queueName": "qsendtogettext",
    "connection": "STORAGEConnectionString"
  }],
  "disabled": false
}

上传PNG到Blob并添加URL到队列的代码 #

blobService.createBlockBlobFromLocalFile(CONTAINER_NAME, BLOCK_BLOB_NAME, './' + FileName, function(error) {
  if (error) {
    context.res = {
      status: 400,
      headers: { 'Content-Type': 'application/json' },
      body: { '__error': error }
    };
    context.done();
  }
  // 上传后删除本地图片
  fs.unlinkSync('./' + FileName);
  context.log(context.bindings)
  context.bindings.myQueueItemii = [blobService.getUrl(CONTAINER_NAME, BLOCK_BLOB_NAME)];
  context.log("added to the q")
});

现在遇到的问题是：Blob URL并没有成功加入到目标队列里，请问我哪里操作错了？

我帮你梳理下问题的核心原因，以及对应的修复方案：

1. 核心问题：未正确触发函数完成逻辑 #

Azure Functions 要求你调用 context.done() 来告知运行时函数执行完毕，这样才会处理所有的输出绑定。你的代码里只在出错时调用了context.done()，但成功流程里完全没调用——这就导致函数可能在赋值输出绑定后直接结束，或者运行时根本没检测到输出绑定的更新，自然不会把URL写入队列。

2. 修复方案（分两种场景） #

场景A：坚持用Storage SDK上传（虽然你说不想用，但先解决当前问题） #

只需要在上传成功的回调末尾加上context.done()即可：

blobService.createBlockBlobFromLocalFile(CONTAINER_NAME, BLOCK_BLOB_NAME, './' + FileName, function(error) {
  if (error) {
    context.res = {
      status: 400,
      headers: { 'Content-Type': 'application/json' },
      body: { '__error': error }
    };
    context.done(error); // 出错时传递错误信息
    return; // 提前退出，避免执行后续逻辑
  }
  // 上传后删除本地图片
  fs.unlinkSync('./' + FileName);
  context.bindings.myQueueItemii = blobService.getUrl(CONTAINER_NAME, BLOCK_BLOB_NAME);
  context.log("added to the q");
  // 必须调用这行，触发输出绑定的提交
  context.done();
});

另外注意：队列输出绑定支持直接赋值字符串，不需要用数组包裹（当然数组也能工作，但单条消息直接传字符串更直观）。

场景B：完全用绑定实现（符合你的初衷，推荐） #

既然你不想用Storage SDK，那可以直接添加Blob输出绑定来上传PNG，这样全程不用手动调用SDK方法：

第一步：修改function.json，添加Blob输出绑定

{
  "bindings": [{
    "name": "pdffaxqueue",
    "type": "queueTrigger",
    "direction": "in",
    "queueName": "pdffaxqueue",
    "connection": "AzureWebJobsStorage"
  }, {
    "type": "queue",
    "direction": "out",
    "name": "myQueueItemii",
    "queueName": "qsendtogettext",
    "connection": "STORAGEConnectionString"
  }, {
    "name": "outputBlob",
    "type": "blob",
    "direction": "out",
    "path": "your-container-name/{rand-guid}.png", // {rand-guid}自动生成唯一文件名，也可以自定义
    "connection": "AzureWebJobsStorage"
  }],
  "disabled": false
}

第二步：修改代码，用绑定上传并处理队列输出

// 读取本地转换好的PNG文件
fs.readFile('./' + FileName, (readErr, fileContent) => {
  if (readErr) {
    context.res = {
      status: 400,
      headers: { 'Content-Type': 'application/json' },
      body: { '__error': readErr }
    };
    context.done(readErr);
    return;
  }

  // 通过Blob输出绑定上传文件，直接赋值文件内容即可
  context.bindings.outputBlob = fileContent;

  // 构造Blob的URL（格式：https://<存储账户名>.blob.core.windows.net/<容器名>/<文件名>）
  const blobUrl = `https://your-storage-account.blob.core.windows.net/your-container-name/${BLOCK_BLOB_NAME}`;
  // 赋值给队列输出绑定
  context.bindings.myQueueItemii = blobUrl;

  // 异步删除本地文件，避免阻塞
  fs.unlink('./' + FileName, (unlinkErr) => {
    if (unlinkErr) {
      context.log('删除本地PNG文件失败:', unlinkErr);
    }
    // 通知函数执行完成，触发所有输出绑定
    context.done();
  });
});

总结 #

不管用哪种方式，必须在函数逻辑完成后调用context.done()，这是触发输出绑定的关键。而用Blob输出绑定的方式更符合你“不用SDK”的需求，也能减少手动处理异步逻辑的出错概率。

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