⌘+k ctrl+k
1.1.3 (stable)
Search Shortcut cmd + k | ctrl + k
S3 Iceberg Import

先决条件

要从S3加载Iceberg文件,需要安装httpfsiceberg扩展。可以使用INSTALL SQL命令进行安装。这些扩展只需安装一次。

INSTALL httpfs;
INSTALL iceberg;

要加载扩展以供使用,请使用 LOAD 命令:

LOAD httpfs;
LOAD iceberg;

凭证

加载扩展后,设置凭据和S3区域以读取数据。您可以使用访问密钥和密钥,或者使用令牌。

CREATE SECRET (
    TYPE S3,
    KEY_ID 'AKIAIOSFODNN7EXAMPLE',
    SECRET 'wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY',
    REGION 'us-east-1'
);

或者,使用 aws 扩展 来自动获取凭证:

CREATE SECRET (
    TYPE S3,
    PROVIDER CREDENTIAL_CHAIN
);

从S3加载Iceberg表

在扩展设置完成并且S3凭证正确配置后,可以使用以下命令从S3读取Iceberg表:

SELECT *
FROM iceberg_scan('s3://⟨bucket⟩/⟨iceberg-table-folder⟩/metadata/⟨id⟩.metadata.json');

请注意,您需要直接链接到清单文件。否则,您将收到类似这样的错误:

IO Error: Cannot open file "s3://⟨bucket⟩/⟨iceberg-table-folder⟩/metadata/version-hint.text": No such file or directory