Skip to content
ClickHouse Docs
ClickHouse DocsClickHouse Docs
49.6kGet Started

Usando o SeaweedFS

View as MarkdownEdit this pageReport an issueSet up docs MCP
Sem suporte no ClickHouse Cloud

A função de tabela s3 e o tipo de disco S3 do ClickHouse são compatíveis com o SeaweedFS, um armazenamento distribuído de objetos de código aberto com um gateway compatível com S3. O SeaweedFS atende nativamente a solicitações no estilo path; portanto, uma instalação self-hosted funciona sem DNS wildcard. O SeaweedFS também oferece suporte a tabelas Iceberg: seus buckets de tabela armazenam os dados em arquivos Parquet, e o catálogo REST Iceberg integrado fornece os metadados das tabelas — consulte o guia do catálogo do SeaweedFS para consultá-las pelo mesmo endpoint.

Use o SeaweedFS 4.42 ou uma versão mais recente. Versões anteriores podem excluir um objeto cuja gravação é confirmada enquanto a pasta pai é removida por estar vazia, o que resulta em Object ... suddenly disappeared logo após uma gravação bem-sucedida.

Executando o SeaweedFS localmente

Para um ambiente de teste local, crie um arquivo s3config.json com as credenciais do S3:

{
  "identities": [
    {
      "name": "analyst",
      "credentials": [
        {
          "accessKey": "your_access_key_id",
          "secretKey": "your_secret_access_key"
        }
      ],
      "actions": ["Admin", "Read", "Write", "List", "Tagging"]
    }
  ]
}

Em seguida, inicie toda a stack do SeaweedFS em um único contêiner — a flag -bucket cria o bucket na inicialização:

docker run -d --name seaweedfs -p 8333:8333 \
  -v "$(pwd)/s3config.json:/etc/seaweedfs/s3config.json" \
  chrislusf/seaweedfs:latest \
  mini -dir=/data -s3.config=/etc/seaweedfs/s3config.json -bucket=clickhouse -admin.port=12646

-admin.port=12646 mantém a porta gRPC de administração derivada pelo SeaweedFS abaixo do intervalo de portas efêmeras do Linux, evitando que uma conexão de inicialização a ocupe primeiro.

O endpoint do S3 está disponível na porta 8333; aguarde até que ele responda antes de continuar:

until curl -s -o /dev/null http://localhost:8333; do sleep 1; done

Mais buckets podem ser criados a qualquer momento com echo "s3.bucket.create -name mybucket" | docker exec -i seaweedfs weed shell.

Por padrão, uma gravação é confirmada assim que é passada ao sistema operacional. Para executar o fsync de cada gravação no disco antes de confirmá-la, habilite o fsync no bucket:

echo "fs.configure -locationPrefix=/buckets/clickhouse/ -fsync -apply" | \
  docker exec -i seaweedfs weed shell

MergeTree com suporte a S3

A configuração do MergeTree com suporte a S3 é compatível com pequenas alterações:

<clickhouse>
    <storage_configuration>
        <disks>
            <s3>
                <type>s3</type>
                <endpoint>http://seaweedfs:8333/clickhouse/tables/</endpoint>
                <access_key_id>your_access_key_id</access_key_id>
                <secret_access_key>your_secret_access_key</secret_access_key>
                <region></region>
                <metadata_path>/var/lib/clickhouse/disks/s3/</metadata_path>
            </s3>
            <s3_cache>
                <type>cache</type>
                <disk>s3</disk>
                <path>/var/lib/clickhouse/disks/s3_cache/</path>
                <max_size>10Gi</max_size>
            </s3_cache>
        </disks>
        <policies>
            <s3_main>
                <volumes>
                    <main>
                        <disk>s3</disk>
                    </main>
                </volumes>
            </s3_main>
        </policies>
    </storage_configuration>
</clickhouse>

As tabelas armazenam seus dados no SeaweedFS por meio da política de armazenamento:

CREATE TABLE trips (id UInt64, rider String, fare Float64)
ENGINE = MergeTree
ORDER BY id
SETTINGS storage_policy = 's3_main';

Para manter um cache local dos dados acessados com frequência, crie a tabela usando SETTINGS disk = 's3_cache' — o disco de cache definido acima envolve o disco S3.

A função de tabela s3

A função de tabela s3 lê e grava objetos no mesmo endpoint:

INSERT INTO FUNCTION s3(
    'http://seaweedfs:8333/clickhouse/sample/trips.parquet',
    'your_access_key_id',
    'your_secret_access_key',
    'Parquet'
)
SELECT number AS id, concat('rider_', toString(number % 10)) AS rider, number * 1.5 AS fare
FROM numbers(1000);

SELECT count()
FROM s3(
    'http://seaweedfs:8333/clickhouse/sample/*.parquet',
    'your_access_key_id',
    'your_secret_access_key',
    'Parquet'
);

Os padrões glob permitem ler vários objetos.

Backup e restauração

BACKUP e RESTORE aceitam um endpoint do SeaweedFS como destino do S3:

BACKUP TABLE trips
TO S3('http://seaweedfs:8333/clickhouse/backups/trips1', 'your_access_key_id', 'your_secret_access_key');

--- DROP TABLE trips;

RESTORE TABLE trips
FROM S3('http://seaweedfs:8333/clickhouse/backups/trips1', 'your_access_key_id', 'your_secret_access_key');
Navigation