LOAD_HISTORY
功能描述:
LOAD_HISTORY
LOAD_HISTORY
函数用于查看表的 COPY 作业导入文件历史,保留期为 7 天。Pipe 在执行时会根据
load_history
load_history
避免重复导入已有的文件,确保数据的唯一性。
函数语法:
load_history('schema_name.table_name')
参数说明:
schema_name.table_name
schema_name.table_name
:指定要查看导入历史的表,格式为 模式名.表名
模式名.表名
。
返回字段:
| 字段 | 类型 | 说明 |
|---|
file_path
file_path | STRING | 导入文件的路径 |
last_copy_time
last_copy_time | TIMESTAMP | 最近一次导入操作的时间 |
file_size
file_size | BIGINT | 文件大小(字节) |
status
status | STRING | 导入状态,LOADED
LOADED 表示成功,LOAD_FAILED
LOAD_FAILED 表示失败 |
first_error_message
first_error_message | STRING | 首次出现的错误信息,成功时为 NULL
NULL |
使用示例:
示例 1:查看表的全部导入历史
SELECT * FROM load_history('myschema.mytable');
示例 2:只查看导入成功的记录
SELECT file_path, last_copy_time, file_size
FROM load_history('myschema.mytable')
WHERE status = 'LOADED';
示例 3:查看导入失败的记录及错误信息
SELECT file_path, last_copy_time, first_error_message
FROM load_history('myschema.mytable')
WHERE status = 'LOAD_FAILED';
示例 4:按时间范围过滤
SELECT * FROM load_history('myschema.mytable')
WHERE last_copy_time > '2026-05-01'
ORDER BY last_copy_time DESC;