MongoDB变更流报错：$_internalChangeStreamOplogMatch仅能作为首阶段

问题现象 #

执行ChangeStream相关代码时触发错误：

$_internalChangeStreamOplogMatch is only valid as the first stage in a pipeline (code 40602)

无论调整管道内阶段顺序，还是仅保留$changeStream阶段，错误均会出现。同时Rust和Node.js驱动都出现相同问题。

需求：

• 仅匹配insert/update/replace/delete类型的操作
• 更新操作时获取完整文档

错误原因 #

你错误地将$changeStream作为管道阶段放入了数组中。实际上$changeStream不是聚合管道的标准阶段，它是watch方法的配置参数，驱动会自动生成内部的$_internalChangeStreamOplogMatch阶段，手动添加$changeStream阶段会导致内部阶段冲突，触发该错误。

正确实现方案 #

Rust 代码示例 #

将fullDocument配置放到watch方法的第二个参数（选项）中，管道仅保留$match阶段：

use mongodb::options::ChangeStreamOptions;
use mongodb::bson::doc;

// 配置ChangeStream选项，设置update时获取完整文档
let change_stream_options = ChangeStreamOptions::builder()
    .full_document(mongodb::options::FullDocument::UpdateLookup)
    .build();

// 聚合管道仅保留$match阶段，过滤指定操作类型
let pipeline = [
    doc! {
        "$match": {
            "operationType": {
                "$in": ["insert", "update", "replace", "delete"]
            }
        }
    },
];

// 传入选项和管道创建ChangeStream
let stream = collection.watch(pipeline, change_stream_options).await?;

Node.js 代码示例（参考） #

同样逻辑，将fullDocument作为watch的配置项，管道单独传入：

const changeStreamOptions = {
  fullDocument: 'updateLookup'
};

const pipeline = [
  {
    $match: {
      operationType: { $in: ['insert', 'update', 'replace', 'delete'] }
    }
  }
];

const stream = collection.watch(pipeline, changeStreamOptions);

这样既满足了过滤操作类型的需求，也实现了更新时获取完整文档的目标。

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