Présentation
La source Snowflake synchronise les données depuis une table ou vue Snowflake dans Reelevant. Utilisez-la pour intégrer les données de votre entrepôt dans vos Workflows de personnalisation.Configuration
Champs obligatoires
Authentification
Snowflake prend en charge deux méthodes d’authentification :- Mot de passe
- Paire de clés
Authentification par nom d’utilisateur et mot de passe.
Champs optionnels
Requêtes SQL personnalisées
Lorsque vous fournissez une requête SQL personnalisée, Reelevant l’exécute sur Snowflake au lieu de lire la table entière. Cela est utile pour :- Filtrer des lignes (par ex.
SELECT * FROM my_table WHERE is_active = TRUE) - Sélectionner des colonnes spécifiques
- Joindre plusieurs tables
- Appliquer des transformations
Synchronisation incrémentale
Snowflake prend en charge la synchronisation incrémentale lorsqu’il est utilisé avec le mode de mise à jour Keep Previous Data.
Lorsque cette option est configurée, Reelevant ajoute une clause
WHERE à votre requête (ou en génère une automatiquement) pour ne récupérer que les lignes où la colonne timestamp est supérieure à la dernière valeur enregistrée.
La colonne timestamp est optionnelle même en mode Keep Previous Data — si votre vue Snowflake gère déjà la logique de delta en interne, vous pouvez l’omettre.
Gestion des types de données
Les types de données Snowflake sont streamés avec les conversions suivantes :Fonctionnement
- Reelevant se connecte à Snowflake avec les identifiants et l’entrepôt fournis.
- Si une requête personnalisée est fournie, elle est exécutée. Sinon,
SELECT * FROM <table>est exécuté. - Les résultats sont streamés ligne par ligne pour une utilisation efficace de la mémoire.
- Les champs sont extraits et rendus disponibles pour le mapping.
- Lors des synchronisations suivantes, les données sont relues (ou récupérées de manière incrémentale si une colonne timestamp est configurée).