slug: /zh/sql-reference/table-functions/s3 sidebar_position: 45

sidebar_label: s3

S3 表函数 {#s3-table-function}

提供类似于表的接口来 select/insert Amazon S3中的文件。这个表函数类似于hdfs，但提供了 S3 特有的功能。

语法

  1. s3(path, [aws_access_key_id, aws_secret_access_key,] format, structure, [compression])

参数

  • path — 带有文件路径的 Bucket url。在只读模式下支持以下通配符: *, ?, {abc,def} 和 {N..M} 其中 N, M 是数字, 'abc', 'def' 是字符串. 更多信息见下文.
  • format — 文件的格式.
  • structure — 表的结构. 格式像这样 'column1_name column1_type, column2_name column2_type, ...'.
  • compression — 压缩类型. 支持的值: none, gzip/gz, brotli/br, xz/LZMA, zstd/zst. 参数是可选的. 默认情况下，通过文件扩展名自动检测压缩类型.

返回值

一个具有指定结构的表，用于读取或写入指定文件中的数据。

示例

从 S3 文件https://storage.yandexcloud.net/my-test-bucket-768/data.csv中选择表格的前两行:

  1. SELECT *
  2. FROM s3('https://storage.yandexcloud.net/my-test-bucket-768/data.csv', 'CSV', 'column1 UInt32, column2 UInt32, column3 UInt32')
  3. LIMIT 2;
  1. ┌─column1─┬─column2─┬─column3─┐
  2. │       1 │       2 │       3 │
  3. │       3 │       2 │       1 │
  4. └─────────┴─────────┴─────────┘

类似的情况，但来源是gzip压缩的文件:

  1. SELECT *
  2. FROM s3('https://storage.yandexcloud.net/my-test-bucket-768/data.csv.gz', 'CSV', 'column1 UInt32, column2 UInt32, column3 UInt32', 'gzip')
  3. LIMIT 2;
  1. ┌─column1─┬─column2─┬─column3─┐
  2. │       1 │       2 │       3 │
  3. │       3 │       2 │       1 │
  4. └─────────┴─────────┴─────────┘

用法 {#usage-examples}

假设我们在S3上有几个文件，URI如下:

计算以数字1至3结尾的文件的总行数:

  1. SELECT count(*)
  2. FROM s3('https://storage.yandexcloud.net/my-test-bucket-768/{some,another}_prefix/some_file_{1..3}.csv', 'CSV', 'name String, value UInt32')
  1. ┌─count()─┐
  2. │      18 │
  3. └─────────┘

计算这两个目录中所有文件的行的总量:

  1. SELECT count(*)
  2. FROM s3('https://storage.yandexcloud.net/my-test-bucket-768/{some,another}_prefix/*', 'CSV', 'name String, value UInt32')
  1. ┌─count()─┐
  2. │      24 │
  3. └─────────┘

!!! warning “Warning” 如果文件列表中包含有从零开头的数字范围，请对每个数字分别使用带括号的结构，或者使用?。

计算名为 file-000.csv, file-001.csv, … , file-999.csv 文件的总行数:

  1. SELECT count(*)
  2. FROM s3('https://storage.yandexcloud.net/my-test-bucket-768/big_prefix/file-{000..999}.csv', 'CSV', 'name String, value UInt32');
  1. ┌─count()─┐
  2. │      12 │
  3. └─────────┘

插入数据到 test-data.csv.gz 文件:

  1. INSERT INTO FUNCTION s3('https://storage.yandexcloud.net/my-test-bucket-768/test-data.csv.gz', 'CSV', 'name String, value UInt32', 'gzip')
  2. VALUES ('test-data', 1), ('test-data-2', 2);

从已有的表插入数据到 test-data.csv.gz 文件:

  1. INSERT INTO FUNCTION s3('https://storage.yandexcloud.net/my-test-bucket-768/test-data.csv.gz', 'CSV', 'name String, value UInt32', 'gzip')
  2. SELECT name, value FROM existing_table;

另请参阅

原始文章