Vous pouvez vous inscrire sur la liste d’attente de la Private Preview ici.
Prérequis
- D’un service ClickHouse Cloud actif
- D’un projet GCP contenant le topic Pub/Sub depuis lequel vous souhaitez ingérer des données
- Des autorisations IAM dans ce projet pour créer des comptes de service et attribuer des rôles
Modèle d’authentification
- répertorier et lire les topics de votre projet,
- créer et supprimer l’abonnement géré que ClickPipes utilise pour consommer les messages,
- consommer les messages de cet abonnement,
- et, éventuellement, lire les schémas Pub/Sub natifs depuis le registre de schémas.
Permissions requises
Accès aux topics (découverte et validation)
Cycle de vie de l’abonnement (découverte et ingestion)
Accès au schéma (optionnel — uniquement pour les topics Avro/Protobuf natifs)
Rôles prédéfinis
Configuration
Créer un rôle personnalisé (recommandé)
gcloud :
Permissions facultativesAjoutez
pubsub.schemas.get à la liste --permissions si vous ingérez depuis des topics qui utilisent des schémas Avro ou Protobuf Pub/Sub natifs. Sinon, laissez-le de côté pour conserver un rôle minimal.roles/pubsub.editor.
Créer un compte de service
Attribuez le rôle au compte de service
roles/pubsub.editor) au compte de service au niveau du projet :
Créer et télécharger une clé d’un compte de service
clickpipes-pubsub-key.json dans ClickPipes UI lors de la création du pipe.
Traitez cette clé comme un secretLes clés de compte de service donnent accès à votre projet GCP. Conservez ce fichier en lieu sûr, ne l’ajoutez pas au contrôle de version et renouvelez la clé régulièrement. ClickPipes chiffre la clé au repos après son import.
Remarques
pubsub.topics.attachSubscriptionest requis sur la ressource topic, et non sur l’abonnement. Ce point est souvent oublié lorsque seules des permissions au niveau de l’abonnement sont accordées.- Si votre topic n’utilise pas de schéma Pub/Sub natif (Avro ou Protobuf), la permission
pubsub.schemas.getn’est pas nécessaire. - Les abonnements gérés sont nommés
clickpipes-{pipeID}avec un ack deadline de 60 s, une rétention des messages de 7 jours et l’ordonnancement des messages activé. - Les abonnements de découverte éphémères sont nommés
clickpipes-discovery-{uuid}avec un ack deadline de 10 s, une rétention de 10 minutes et un TTL d’expiration automatique de 24 heures. - ClickPipes traite les erreurs
PermissionDeniedetUnauthenticatedcomme non réessayables — si une permission est manquante, le pipeline échoue immédiatement au lieu de réessayer indéfiniment.