MongoDB Client Cursor数据获取异常：如何将stream结果赋值给变量？

你得到整个Cursor对象的原因很直接：cursor.stream()返回的是Node.js可读流实例，而.on("data", ...)是给这个流注册事件监听器的方法，它的返回值还是原流对象（链式调用的设计），所以你赋值给schema的是流本身，不是回调里的文档数据。另外，流的事件是异步触发的，同步赋值的方式根本抓不到异步返回的结果。

正确获取并绑定结果的方法 #

方法1：用Promise封装（推荐，适合异步流程）

因为流是异步的，我们可以用Promise包裹流的事件，等流结束后拿到完整结果，还能配合async/await让代码更清爽：

function fetchSchema(cursor) {
  return new Promise((resolve, reject) => {
    let targetSchema;
    const stream = cursor.stream();

    stream.on("data", (doc) => {
      // 直接提取你需要的schema字段
      targetSchema = doc.schema;
      stream.destroy(); // 单文档场景下拿到数据就关闭流，节省资源
    });

    stream.on("end", () => {
      resolve(targetSchema);
    });

    stream.on("error", (err) => {
      reject(err);
    });
  });
}

// 使用示例
async function main() {
  try {
    // 替换成你的聚合管道和集合名
    const cursor = db.collection('your-collection').aggregate([/* 你的聚合条件 */]);
    const schema = await fetchSchema(cursor);
    // 这里就能正常使用schema变量了
    console.log(schema);
  } catch (err) {
    console.error('获取schema失败:', err);
  }
}

main();

方法2：直接监听事件处理（适合简单场景）

如果只是在脚本里快速处理单文档，也可以直接在事件回调里处理结果：

// 替换成你的聚合管道和集合名
const cursor = db.collection('your-collection').aggregate([/* 你的聚合条件 */]);
let schema;

const stream = cursor.stream();
stream.on("data", (doc) => {
  schema = doc.schema;
  stream.destroy(); // 拿到数据后立即关闭流
});

stream.on("end", () => {
  if (schema) {
    // 在这里使用schema变量做后续操作
    console.log(schema);
  } else {
    console.log('未找到目标文档');
  }
});

stream.on("error", (err) => {
  console.error('处理出错:', err);
});

补充说明 #

你用stream替代toArray()的思路是对的：toArray()会把整个嵌套深的大文档一次性加载到内存，而stream是分块读取处理，能有效降低内存占用、提升速度。

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