如何在Rust中编写MongoDB ChangeStream管道跟踪指定记录变更？

你的问题出在ChangeStream返回的是变更事件文档，而非集合中的原始文档，直接匹配author.id找不到对应字段，正确的匹配路径应该指向事件中的fullDocument嵌套字段，同时还要处理更新操作的特殊情况。

修正步骤 #

• 调整$match管道的匹配路径，改为fullDocument.author.id，因为集合的文档数据会被包裹在变更事件的fullDocument字段中。
• 若需要跟踪update类型的变更，必须配置ChangeStream选项，开启UpdateLookup模式，确保更新事件能返回完整的文档内容，否则fullDocument字段在update事件中默认不存在。

修正后的完整代码 #

use mongodb::options::{ChangeStreamOptions, FullDocument};

async fn websocket(socket: WebSocket, state: State<AppState>, user_id: ObjectId) {
    let (mut sender, _receiver) = socket.split();

    // 修正匹配路径，指向fullDocument中的author.id
    let pipeline = vec![doc! {
        "$match": {
            "fullDocument.author.id": user_id
        }
    }];

    // 配置ChangeStream选项，确保update事件返回完整文档
    let change_stream_options = ChangeStreamOptions::builder()
        .full_document(Some(FullDocument::UpdateLookup))
        .build();

    let change_stream = state
        .db
        .posts_collection
        .watch(pipeline, change_stream_options)
        .await
        .map_err(|err| {
            eprintln!("Error creating change stream: {:?}", err);
            "Failed to create change stream".to_string()
        });
}

额外说明 #

• 如果只需要跟踪insert或replace类型的变更，不配置full_document选项也能正常工作，因为这两类事件默认会返回fullDocument。
• 若要同时过滤变更操作类型（比如只跟踪insert和update），可以在管道中添加额外的匹配条件：

  let pipeline = vec![doc! {
      "$match": {
          "$and": [
              { "fullDocument.author.id": user_id },
              { "operationType": { "$in": ["insert", "update", "replace"] } }
          ]
      }
  }];
  

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