change streams 不支持 ddl 过滤，因官方主动屏蔽 oplog 中的 command 类型事件（如 createindex）；仅暴露 crud 和 invalidate 事件，server-46979 确认该限制长期存在且无开放计划。
Change Streams 本身不支持 DDL 过滤，$changeStream pipeline 中无法监听 createIndex、dropIndex、shardCollection 等操作 —— 这是 MongoDB 官方明确不支持的边界。
为什么 $changeStream 不能过滤 DDL 操作
MongoDB 的 Change Streams 底层基于 oplog 变更事件，但只暴露了 CRUD 类型的操作（insert、update、replace、delete、invalidate），而 DDL 操作（如建索引、分片）在 oplog 中虽有记录（command 类型），但被 $changeStream stage 主动屏蔽。官方 JIRA SERVER-46979 已确认该限制长期存在，且无计划在 6.0 或 7.0 中开放。
常见错误现象包括：
- 在
watch()pipeline 中加入{$match: {operationType: "command"}}，结果始终收不到任何事件 - 用
db.adminCommand({listCommands: 1})查到命令存在，但$changeStream不触发 - 误以为
fullDocument: "whenAvailable"能捕获 schema 变更，实际仅影响文档级变更的全量字段返回
想同步「部分字段变更」只能靠 $project + $match 组合
Change Streams 支持在聚合 pipeline 中对变更事件做预过滤和投影，这是唯一可控的“字段级同步”路径 —— 注意：这里指「变更事件中携带的字段」，不是数据库 schema 字段。
例如，只关心 users 集合中 status 和 lastLogin 字段变化，并忽略 updatedAt 自增字段：
db.users.watch([
{
$match: {
"operationType": { $in: ["update", "replace"] },
"updateDescription.updatedFields.status": { $exists: true },
"updateDescription.updatedFields.lastLogin": { $exists: true }
}
},
{
$project: {
_id: 1,
operationType: 1,
"fullDocument._id": 1,
"fullDocument.status": 1,
"fullDocument.lastLogin": 1,
"updateDescription.updatedFields.status": 1,
"updateDescription.updatedFields.lastLogin": 1,
"updateDescription.removedFields": 1
}
}
])
关键点：
-
$match必须用updateDescription.updatedFields.xxx路径判断字段是否被修改，不能直接匹配fullDocument.status（它反映的是最终值，不是变更动作） -
$project里显式列出字段，否则默认返回整个fullDocument（可能超 16MB 限制） - 若需区分「字段被设为 null」和「字段未更新」，得结合
updatedFields与removedFields两个字段判断
DDL 同步需求的实际替代方案
当业务真需要响应索引创建、集合分片等操作时，必须绕过 Change Streams：
- 在应用层统一调用封装好的 DDL 函数（如
createIndexWithHook()），执行前发消息到 Kafka / Redis PubSub，下游监听消费 - 对分片集群，定期轮询
config.chunks和config.collections集合变化（注意权限与性能开销） - 使用 MongoDB Atlas 时，可开启
Atlas Audit Logs，通过 Webhook 或 S3 导出解析createIndex类日志（仅限托管服务） - 自建环境可部署
mongod日志采集器（如 Filebeat + Grok），过滤"cmd":"createIndexes"日志行 —— 但日志格式非稳定 API，升级易断裂
真正容易被忽略的是：Change Streams 的 resume token 在 DDL 操作后可能失效（比如 shardCollection 触发 chunk 拆分），导致客户端重连时从头开始或跳过中间事件。这不是 bug，是设计使然 —— 因为 DDL 不产生变更事件，但会扰动底层 oplog 流水线位置。
