Você pode entrar na lista de espera da prévia privada aqui.
Pré-requisitos
- Um serviço ClickHouse Cloud ativo
- Um projeto no GCP que contenha o tópico do Pub/Sub a partir do qual você deseja fazer a ingestão
- Permissões de IAM nesse projeto para criar contas de serviço e conceder funções
Modelo de autenticação
- listar e ler os tópicos no seu projeto,
- criar e excluir a assinatura gerenciada que o ClickPipes usa para consumir mensagens,
- consumir mensagens dessa assinatura, e
- (opcionalmente) ler esquemas nativos do Pub/Sub no registro de esquemas.
Permissões necessárias
Acesso a tópicos (descoberta e validação)
Ciclo de vida da assinatura (descoberta e ingestão)
Acesso ao esquema (opcional — apenas para tópicos Avro/Protobuf nativos)
Papéis predefinidos
Setup
Crie uma função personalizada (recomendado)
gcloud:
Permissões opcionaisAdicione
pubsub.schemas.get à lista --permissions se você fizer ingestão de tópicos que usam esquemas Avro ou Protobuf nativos do Pub/Sub. Caso contrário, deixe-o de fora para manter o papel no mínimo necessário.roles/pubsub.editor em vez dele.
Criar uma conta de serviço
Conceda o papel à conta de serviço
roles/pubsub.editor) à conta de serviço no nível do projeto:
Crie e baixe uma chave da conta de serviço
clickpipes-pubsub-key.json na UI do ClickPipes ao criar o pipe.
Trate a chave como um segredoAs chaves da conta de serviço concedem acesso ao seu projeto no GCP. Armazene o arquivo com segurança, não faça
commit dele no controle de versão e faça a rotação periodicamente. O ClickPipes criptografa a chave em repouso após o upload.Notas
pubsub.topics.attachSubscriptioné necessário no recurso de tópico, não na assinatura. Isso geralmente passa despercebido quando são concedidas apenas permissões no nível da assinatura.- Se o seu tópico não usa um esquema nativo do Pub/Sub (Avro ou Protobuf), a permissão
pubsub.schemas.getnão é necessária. - As assinaturas gerenciadas são nomeadas como
clickpipes-{pipeID}, com ack deadline de 60s, retenção de mensagens por 7 dias e ordenação de mensagens ativada. - As assinaturas efêmeras de descoberta são nomeadas como
clickpipes-discovery-{uuid}, com ack deadline de 10s, retenção de 10 minutos e TTL de expiração automática de 24 horas. - O ClickPipes trata os erros
PermissionDeniedeUnauthenticatedcomo não retentáveis — se estiver faltando uma permissão, o pipe falha imediatamente em vez de tentar novamente indefinidamente.