增量抽取水位列与半开区间

用更新时间列做水位是最常见的增量方式：记录上一次抽取到的高水位值，下次只取大于它的数据。用「大于等于左边界、小于右边界」的半开区间避免边界重复与丢失。

增量 SQL 模板

SELECT id, amount, updated_at
FROM source_order
WHERE updated_at >= :last_watermark
  AND updated_at <  :window_end
ORDER BY updated_at;

UPDATE etl_watermark
SET last_value = :window_end, updated_at = NOW()
WHERE job_name = 'order_incr';

用「大于」而非「大于等于」会在同一时间戳多条记录时丢数据；用半开区间并以窗口结束时间推进水位更稳。

‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌‌