从 Snowflake 迁移
在本教程中，我们将指导您将数据从 Snowflake 以 Parquet 格式导出到 Amazon S3 存储桶，然后将其加载到 Databend Cloud 中。
开始之前
在开始之前，请确保您已准备好以下先决条件：
- Amazon S3 存储桶：一个 S3 存储桶，用于存储 导出的数据，并具有上传文件所需的权限。了解如何创建 S3 存储桶。在本教程中，我们使用
s3://databend-doc/snowflake/作为导出数据的暂存位置。 - AWS 凭证：具有足够权限访问 S3 存储桶的 AWS 访问密钥 ID 和秘密访问密钥。管理您的 AWS 凭证。
- 管理 IAM 角色和策略的权限：确保您具有创建和管理 IAM 角色和策略的必要权限，这些权限是配置 Snowflake 和 Amazon S3 之间访问所必需的。了解 IAM 角色和策略。
步骤 1：为 Amazon S3 配置 Snowflake 存储集成
在此步骤中，我们将配置 Snowflake 使用 IAM 角色访问 Amazon S3。首先，我们将创建一个 IAM 角色，然后使用该角色建立 Snowflake 存储集成以实现安全数据访问。
- 登录 AWS 管理控制台，然后在 IAM > 策略 中创建一个策略，使用以下 JSON 代码：
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"s3:PutObject",
"s3:GetObject",
"s3:GetObjectVersion",
"s3:DeleteObject",
"s3:DeleteObjectVersion"
],
"Resource": "arn:aws:s3:::databend-doc/snowflake/*"
},
{
"Effect": "Allow",
"Action": [
"s3:ListBucket",
"s3:GetBucketLocation"
],
"Resource": "arn:aws:s3:::databend-doc",
"Condition": {
"StringLike": {
"s3:prefix": [
"snowflake/*"
]
}
}
}
]
}
此策略适用于名为 databend-doc 的 S3 存储桶，特别是该存储桶中的 snowflake 文件夹。
s3:PutObject,s3:GetObject,s3:GetObjectVersion,s3:DeleteObject,s3:DeleteObjectVersion：允许对 snowflake 文件夹中的对象进行操作（例如，s3://databend-doc/snowflake/）。您可以在此文件夹中 上传、读取和删除对象。s3:ListBucket,s3:GetBucketLocation：允许列出databend-doc存储桶的内容并检索其位置。Condition元素确保列出仅限于snowflake文件夹中的对象。
-
在 IAM > 角色 中创建一个名为
databend-doc-role的角色，并附加我们创建的策略。- 在创建角色的第一步中，选择 AWS 账户 作为 受信任的实体类型，并选择 此账户 (xxxxx) 作为 AWS 账户。
- 角色创建完成后，复制并安全保存角色的 ARN，例如
arn:aws:iam::123456789012:role/databend-doc-role。 - 我们将在获取 Snowflake 账户的 IAM 用户 ARN 后更新角色的 信任关系。
-
在 Snowflake 中打开一个 SQL 工作表，并使用角色 ARN 创建一个名为
my_s3_integration的存储集成。
CREATE OR REPLACE STORAGE INTEGRATION my_s3_integration
TYPE = EXTERNAL_STAGE
STORAGE_PROVIDER = 'S3'
STORAGE_AWS_ROLE_ARN = 'arn:aws:iam::123456789012:role/databend-doc-role'
STORAGE_ALLOWED_LOCATIONS = ('s3://databend-doc/snowflake/')
ENABLED = TRUE;
- 显示存储集成详情并获取结果中
STORAGE_AWS_IAM_USER_ARN属性的值，例如arn:aws:iam::123456789012:user/example。我们将在下一步中使用此值更新角色databend-doc-role的 信任关系。
DESCRIBE INTEGRATION my_s3_integration;
- 返回 AWS 管理控制台，打开角色
databend-doc-role，并导航到 信任关系 > 编辑信任策略。将以下代码复制到编辑器中：
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"AWS": "arn:aws:iam::123456789012:user/example"
},
"Action": "sts:AssumeRole"
}
]
}
ARN arn:aws:iam::123456789012:user/example 是我们在上一步中获取的 Snowflake 账户的 IAM 用户 ARN。
步骤 2：准备并导出数据到 Amazon S3
- 在 Snowflake 中使用 Snowflake 存储集成
my_s3_integration创建一个外部阶段：
CREATE OR REPLACE STAGE my_external_stage
URL = 's3://databend-doc/snowflake/'
STORAGE_INTEGRATION = my_s3_integration
FILE_FORMAT = (TYPE = 'PARQUET');
URL = 's3://databend-doc/snowflake/' 指定了数据将被暂存的 S3 存储桶和文件夹。路径 s3://databend-doc/snowflake/ 对应于 S3 存储桶 databend-doc 和该存储桶中的 snowflake 文件夹。
- 准备一些要导出的数据。
CREATE DATABASE doc;
USE DATABASE doc;
CREATE TABLE my_table (
id INT,
name STRING,
age INT
);
INSERT INTO my_table (id, name, age) VALUES
(1, 'Alice', 30),
(2, 'Bob', 25),
(3, 'Charlie', 35);
- 使用 COPY INTO 将表数据导出到外部阶段：
COPY INTO @my_external_stage/my_table_data_
FROM my_table
FILE_FORMAT = (TYPE = 'PARQUET') HEADER=true;
如果您现在打开存储桶 databend-doc，您应该会在 snowflake 文件夹中看到一个 Parquet 文件：
步骤 3：将数据加载到 Databend Cloud
- 在 Databend Cloud 中创建目标表：
CREATE DATABASE doc;
USE DATABASE doc;
CREATE TABLE my_target_table (
id INT,
name STRING,
age INT
);
- 使用 COPY INTO 从存储桶中加载导出的数据：
COPY INTO my_target_table
FROM 's3://databend-doc/snowflake'
CONNECTION = (
ACCESS_KEY_ID = '<your-access-key-id>',
SECRET_ACCESS_KEY = '<your-secret-access-key>'
)
PATTERN = '.*[.]parquet'
FILE_FORMAT = (
TYPE = 'PARQUET'
);
- 验证加载的数据：
SELECT * FROM my_target_table;
┌──────────────────────────────────────────────────────┐
│ id │ name │ age │
├─────────────────┼──────────────────┼─────────────────┤
│ 1 │ Alice │ 30 │
│ 2 │ Bob │ 25 │
│ 3 │ Charlie │ 35 │
└──────────────────────────────────────────────────────┘
