MongoDB使用$lookup聚合关联两集合手机号字段失效问题求助

核心规则提醒：$lookup 中 let 定义的变量、主流程的字段引用，都属于发起关联的主集合；pipeline 内部的字段引用，都属于被关联的 from 集合，搞反边界是这类问题最常见的诱因。

原代码完全混淆了两个集合的字段归属，导致关联逻辑完全失效，具体问题有三个：

• 关联变量提取方向错误：$lookup 是从主集合（也就是 messages_client 对应的 Messages 集合）发起的，let 字段里定义的临时变量，必须从当前主集合的文档字段中提取。原代码写 'phone': "$phone"，但 Messages 集合根本没有 phone 字段，存的是带 tel: 前缀的 Tel 字段，导致传入关联流程的临时变量值永远是 null。
• 被关联集合的字段引用错误：$lookup 内部的 pipeline 是针对被关联的 from 集合（也就是 contacts 联系人集合）执行的流程，流程中引用的字段默认都是属于 contacts 集合的。原代码在这个 pipeline 里用 $Tel 做字符串截取，但 Tel 是 Messages 集合的字段，contacts 集合根本不存在这个字段，所以截取得到的手机号也永远是 null。
• 输出结构不匹配：$lookup 执行完成后，as 字段的结果永远是数组类型，无法直接输出你需要的单个 contact 嵌套对象结构。加上前面两个字段引用错误的问题，最终两个匹配计算值都是 null，MongoDB 会判定 null == null 为真，导致所有联系人文档都被塞进结果数组，完全达不到按手机号关联的效果。

核心调整逻辑是把字段处理的边界归位：在主集合 Messages 侧完成手机号的格式截取，把纯手机号作为临时变量传给关联流程，再在 contacts 集合侧做匹配，最后把数组类型的匹配结果转成单个嵌套对象。
完整可运行的 PyMongo 聚合代码如下：

cursor = messages_client.aggregate([
    {
        '$lookup': {
            'from': "contacts",
            # 从Messages文档自身的Tel字段提取纯手机号，去掉"tel:"前缀，作为关联临时变量
            'let': { 
                'msg_phone': { "$substr": [ "$Tel", 4, -1 ] }
            },
            # 在contacts集合上执行匹配逻辑
            'pipeline': [
                # 匹配规则：联系人的手机号和从消息里提取的纯手机号一致
                { 
                    '$match': { 
                        "$expr": { '$eq': [ "$phone", "$$msg_phone" ] }
                    }
                },
                # 只保留需要的联系人字段，减少冗余数据传输
                { '$project': { 'phone': 1, 'name': 1, '_id': 0 }}
            ],
            'as': 'contact_raw'
        }
    },
    {
        '$addFields': {
            # 一对一关联场景下，取数组第一个元素作为嵌套的contact对象
            'contact': { '$arrayElemAt': [ "$contact_raw", 0 ] },
            # 删除中间用的临时字段
            'contact_raw': "$$REMOVE"
        }
    }
], allowDiskUse=True)

执行上述聚合逻辑后，输出的文档结构会和预期完全一致，Messages 集合自带的 text 字段会随文档保留，关联得到的联系人信息会以单个对象的形式嵌套在 contact 字段下。
如果出现匹配率偏低的情况，可以核对两个集合提取后的手机号格式是否完全一致（比如是否存在前后空格、隐藏特殊字符、国家码不一致等问题），再对应调整字符串截取的起始位置即可。

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