从存储桶加载数据
当数据文件存储在对象存储桶(如 Amazon S3)中时,可以使用 COPY INTO 命令直接将它们加载到 Databend 中。请注意,文件必须采用 Databend 支持的格式,否则数据无法导入。有关 Databend 支持的文件格式的更多信息,请参阅 输入 & 输出文件格式。
本教程以 Amazon S3 存储桶为例,提供详细的步骤指南,帮助您有效地从存储桶中存储的文件加载数据。
教程:从 Amazon S3 存储桶加载数据
开始之前
在开始之前,请确保已完成以下任务:
- 下载并保存示例文件 books.parquet 到本地文件夹。该文件包含两条记录:
books.parquet
Transaction Processing,Jim Gray,1992
Readings in Database Systems,Michael Stonebraker,2004
- 在 Amazon S3 中创建一个存储桶,并将示例文件上传到该存储桶。有关如何操作,请参阅以下链接:
- 创建存储桶:https://docs.aws.amazon.com/AmazonS3/latest/userguide/create-bucket-overview.html
- 上传对象:https://docs.aws.amazon.com/AmazonS3/latest/userguide/upload-objects.html
在本教程中,在 US East (Ohio) 区域(ID: us-east-2)创建了一个名为 databend-toronto 的存储桶。
步骤 1. 创建目标表
使用以下 SQL 语句在 Databend 中创建一个表:
USE default;
CREATE TABLE books
(
title VARCHAR,
author VARCHAR,
date VARCHAR
);
步骤 2. 将数据复制到表中
- 使用 COPY INTO 命令将数据加载到目标表中:
COPY INTO books
FROM 's3://databend-toronto/'
CONNECTION = (
AWS_KEY_ID = '<my-access-key-id>',
AWS_SECRET_KEY = '<your-secret-access-key>',
REGION = 'us-east-2'
)
PATTERN = '.*[.]parquet'
FILE_FORMAT = (
TYPE = 'PARQUET'
);
- 检查加载的数据:
SELECT * FROM books;
---
title |author |date|
----------------------------+-------------------+----+
Transaction Processing |Jim Gray |1992|
Readings in Database Systems|Michael Stonebraker|2004|