delta lake 的 time travel 支持按版本号或时间戳查询历史数据，通过 describe history 查看变更详情，restore table 或 insert overwrite 实现安全回滚，配合 vacuum 设置保留策略及 dataframe api 实现可复现 etl。
Delta Lake 的 time travel 功能让你能像操作 Git 一样回溯表的历史状态，查任意版本的数据、恢复误删内容、做数据审计或对比变更。关键不在于“能不能”，而在于怎么用得准、用得稳。
用 VERSION AS OF 查指定快照
Delta Lake 为每次写入（包括 INSERT、UPDATE、DELETE、MERGE）自动递增版本号，从 0 开始。你可以直接按版本号查询历史数据：
- SELECT * FROM events VERSION AS OF 5; —— 查第 6 次写入后的快照（版本号从 0 起算）
- SELECT * FROM events TIMESTAMP AS OF '2024-03-15T10:30:00.000Z'; —— 按时间戳查（需时区一致，推荐用 UTC）
注意：VERSION 和 TIMESTAMP 是互斥的，不能同时用；时间戳查询依赖 _delta_log 中的 commit 时间，不是系统本地时间。
查看历史变更记录（DESCRIBE HISTORY）
知道有哪些版本只是第一步，真正要理解“为什么有这个版本”，得看提交日志：
- DESCRIBE HISTORY events; 返回每条 commit 的 version、timestamp、operation（如 WRITE、DELETE、UPDATE）、operationParameters、userMetadata 等
- 常用过滤：DESCRIBE HISTORY events LIMIT 10; 或加 WHERE 子句筛选 operation = 'DELETE'
- 建议在写入时带上业务上下文：spark.conf.set("spark.databricks.delta.commitInfo.userMetadata", "batch_id=20240315_v2")，方便后续追踪
安全回滚与数据修复
Time travel 不是只读能力——它可支撑可靠的数据修复流程：
- 恢复整张表到某版本：RESTORE TABLE events TO VERSION AS OF 3;（Databricks Runtime 11.3+ 支持，开源 Delta 仅支持读取）
- 若暂无 RESTORE 权限，可用 SELECT + INSERT 替代：INSERT OVERWRITE events SELECT * FROM events VERSION AS OF 3;
- 慎用 DELETE 后立即 VACUUM：VACUUM 默认保留 7 天旧文件，但一旦清理，对应版本将不可访问。生产环境建议设为 VACUUM events RETAIN 168 HOURS;（7天）并监控 retention period 警告
结合 Spark DataFrame API 实现版本感知 ETL
在代码中动态使用 time travel，让作业具备可复现性：
- 读取指定版本：spark.read.format("delta").option("versionAsOf", "5").load("/path/to/table")
- 对比两个版本差异：df_v10 = spark.read.option("versionAsOf", 10).table("sales"); df_v11 = spark.read.option("versionAsOf", 11).table("sales"); df_v11.exceptAll(df_v10).show()
- 构建增量拉链表时，用 versionAsOf 获取“上一周期快照”，避免因并发写入导致逻辑错位
