Django ORM无外键场景下基于时间戳实现双字段内连接的方法

实现方案 #

Django ORM 无外键双字段内连接可通过以下三种方式实现，均能达到示例原生SQL的等效效果：

方案1：Subquery + OuterRef（最通用，官方推荐） #

无需修改模型定义，仅通过子查询关联匹配字段，加非空过滤即可实现内连接效果：

from django.db.models import Subquery, OuterRef
from .models import ChangeEvent, AisData
from datetime import datetime, timedelta

start_period = datetime.now() - timedelta(hours=24)
end_period = datetime.now()

# 定义关联AisData取geom的子查询
ais_geom_sub = AisData.objects.filter(
    imo=OuterRef("imo"),
    start_ts=OuterRef("timestamp")
).values("geom")[:1]

# 筛选24小时内的ChangeEvent，关联标注geom，过滤掉无匹配的记录（等效内连接）
result = ChangeEvent.objects.filter(
    timestamp__gte=start_period,
    timestamp__lte=end_period
).annotate(
    geom=Subquery(ais_geom_sub)
).filter(geom__isnull=False)

最终返回的result每个对象都会携带geom属性，仅保留两个表字段完全匹配的记录。

方案2：FilteredRelation（适合多字段关联/后续聚合场景） #

Django 2.0+ 提供的FilteredRelation专门用于自定义无外键的关联条件，生成的SQL直接为JOIN结构，性能更优：

from django.db.models import F, FilteredRelation, Q
from .models import ChangeEvent, AisData
from datetime import datetime, timedelta

start_period = datetime.now() - timedelta(hours=24)
end_period = datetime.now()

result = ChangeEvent.objects.filter(
    timestamp__gte=start_period,
    timestamp__lte=end_period
).annotate(
    ais_link=FilteredRelation(
        "aisdata",
        condition=Q(imo=F("aisdata__imo")) & Q(timestamp=F("aisdata__start_ts"))
    )
).values(
    "event_id", "imo", "timestamp", "aisdata__geom"
)

返回结果中aisdata__geom即为关联到的空间字段，如需获取更多AisData字段直接在values中添加即可。

方案3：extra（快速实现，不推荐长期使用） #

方法简单直观，但Django官方已标记该接口为待废弃，仅适合临时快速验证场景：

from .models import ChangeEvent
from datetime import datetime, timedelta

start_period = datetime.now() - timedelta(hours=24)
end_period = datetime.now()

result = ChangeEvent.objects.filter(
    timestamp__gte=start_period,
    timestamp__lte=end_period
).extra(
    tables=["ais_data"],
    where=[
        "change_event.imo = ais_data.imo",
        "change_event.timestamp = ais_data.start_ts"
    ],
    select={"geom": "ais_data.geom"}
)

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