年と月ごとに S3 にパーティション分けして書き込む方法
S3 バケット内のパスを分けて、次のような構造になるようにデータをエクスポートしたいです。
- 2022
- 1
- 2
- …
- 12
- 2021
- 1
- 2
- …
- 12
など …
回答
次の ClickHouse のテーブルについて考えてみましょう。
CREATE TABLE sample_data (
`name` String,
`age` Int,
`time` DateTime
) ENGINE = MergeTree
ORDER BY
name10000件のエントリを追加します:
INSERT INTO
sample_data
SELECT
*
FROM
generateRandom(
'name String, age Int, time DateTime',
10,
10,
10
)
LIMIT
10000;次を実行して、S3 バケット my_bucket に必要な構造を作成します (この例ではファイルを Parquet フォーマットで書き込みます) :
INSERT INTO
FUNCTION s3(
'https://s3-host:4321/my_bucket/{_partition_id}/file.parquet.gz',
's3-access-key',
's3-secret-access-key',
Parquet,
'name String, age Int, time DateTime'
) PARTITION BY concat(
formatDateTime(time, '%Y'),
'/',
formatDateTime(time, '%m')
)
SELECT
name,
age,
time
FROM
sample_data
Query id: 55adcf22-f6af-491e-b697