如何在Snowflake中访问外部挂载Iceberg表的metadata_log_entries元数据文件？

安全阿岳

2026-6-16

Snowflake访问Iceberg外部表元数据及UDF应用解答

1. 能否访问Iceberg元数据JSON和metadata_log_entries文件？

可以直接访问。Snowflake挂载的Iceberg表基于外部存储（如S3、ADLS等），这些元数据文件本身存储在外部存储的table_path/metadata/目录下，你可以通过以下操作读取：

创建外部阶段指向Iceberg表的元数据目录
用LIST @your_stage查看目录下的vX.metadata.json和metadata_log_entries.json等文件
执行SELECT $1 FROM @your_stage/metadata/metadata_log_entries.json直接读取文件内容，Snowflake会自动解析JSON格式

此外，也可以通过Snowflake系统视图INFORMATION_SCHEMA.ICEBERG_TABLES间接获取元数据信息，但直接读取原始文件能拿到更完整的日志细节。

2. 能否用于UDF生成时间旅行时间戳？

完全可行，具体步骤如下：

读取metadata_log_entries.json文件，解析其中的snapshot-id和对应的timestamp-ms字段（Iceberg日志记录了每个快照的生成时间）
创建自定义UDF，输入快照ID或时间范围，输出对应时间戳；也可以直接提取所有可用时间戳供外部用户选择
结合Snowflake对Iceberg的时间旅行支持，用户可使用生成的时间戳，通过SELECT * FROM your_iceberg_table AT(TIMESTAMP => '<timestamp>')查询历史数据

以下是一个简单的JavaScript UDF示例：

CREATE OR REPLACE FUNCTION GET_ICEBERG_SNAPSHOT_TIMESTAMPS()
RETURNS ARRAY
LANGUAGE JAVASCRIPT
AS $$
    const logResult = snowflake.execute({sqlText: "SELECT $1 FROM @iceberg_metadata_stage/metadata/metadata_log_entries.json"});
    const logData = logResult.next().getColumnValue(1);
    const entries = JSON.parse(logData);
    return entries.map(entry => entry.timestamp_ms);
$$;

调用该UDF可获取所有快照对应的时间戳数组，供外部用户使用。