Blog/Analytics/Analytique en temps réel sur Snowflake : bien frais et servis à point nommé, les flux coulent à flots
3 nov. 2026/Lecture : 12 minAnalytics

Analytique en temps réel sur Snowflake : bien frais et servis à point nommé, les flux coulent à flots

Graphic showing the ingestion, transformation, activation workflow for AI-ready data

Chaque interaction client est une occasion de gagner leur confiance ou de perdre leur attention. Pour rester compétitives, les entreprises doivent agir avant même la fin de cette interaction. Une équipe des services financiers a besoin des dernières données de marché pour discuter avec ses clients des ajustements à apporter à leur portefeuille. Une équipe des opérations réseau doit savoir dès qu’un réseau commence à se dégrader afin d’aider les clients concernés pendant leur échange avec le support. Un retailer doit personnaliser l’expérience pendant que le client effectue encore ses achats et optimiser ses stocks en fonction de la demande en temps réel. Et un agent d’IA a besoin d’un contexte fiable, actuel et précis pour recommander la meilleure action à entreprendre, résoudre un problème ou éclairer une décision.

Dans chaque cas, la valeur des données dépend de la rapidité avec laquelle les équipes passent de l’observation à l’action. Lorsqu’une équipe détecte rapidement un problème, en comprend l’impact et agit sur-le-champ, elle augmente son chiffre d’affaires, améliore l’expérience client et prend de meilleures décisions. Cette urgence et cette rapidité d’accès aux informations peuvent différencier votre business de la concurrence. Pourtant, construire un stack en temps réel a souvent nécessité d’assembler manuellement des systèmes distincts pour l’ingestion, la transformation et la mise à disposition : connecter les producteurs à un broker de messages, déployer des tâches de transformation séparées et charger les résultats dans une nouvelle base de données. Chaque couche ajoute de l’infrastructure à exploiter, des spécialistes à recruter, des pipelines susceptibles de tomber en panne, des coûts à maîtriser et de nouvelles règles de sécurité à maintenir.

C’est pourquoi Snowflake lance une expérience connectée qui rend l’analytique en temps réel plus simple à créer, plus économique à faire évoluer et gouvernée à chaque étape. Elle réunit la connectivité, la transformation et la mise à disposition dans les tables natives Snowflake et les tables Apache Iceberg™, afin que les équipes transforment les données récentes en décisions sans gérer de stack fragmenté ni renoncer au libre choix de leurs moteurs et outils.

Découvrez Snowflake pour l’analytique en temps réel

L’analytique en temps réel permet de transformer des données actualisées en informations fiables et en actions concrètes en quelques secondes. L’analytique en temps réel traite et analyse les données à mesure que les événements se produisent. Elle offre aux utilisateurs et aux systèmes une vision actuelle de la situation, avec une latence adaptée à chaque charge de travail.

Schéma « Before » d'une architecture streaming temps réel fragmentée. Les sources (applications et services, appareils IoT, topics Kafka, agents IA) alimentent quatre blocs successifs. Le premier est le bus de messages, un cluster Kafka avec ses brokers. Le deuxième est le moteur de traitement, avec des jobs Flink ou Spark. Le troisième est une base de service à faible latence. Le dernier regroupe les applications et tableaux de bord pour analystes, utilisateurs et IA. Chaque étape ajoute une copie des données, un runtime ou un modèle de sécurité supplémentaire. Un connecteur alimente aussi un entrepôt analytique, synchronisé avec la base de service par des jobs de synchronisation : encore une copie, encore une synchronisation. Des pictogrammes d'alerte et de coût ($$) soulignent le résultat : stockage en silos, moteurs multiples, gouvernance fragmentée.
Figure 1 : Architecture traditionnelle d’analytique en temps réel.

 

Snowflake réunit désormais la connectivité, la transformation et la mise à disposition pour assurer une analytique en temps réel de bout en bout. Cet article présente ces fonctionnalités : connecter les données, les transformer à la volée et les servir rapidement. Snowflake répond aux besoins suivants sans obliger les équipes à reconstruire leur architecture pour chacun d’eux.

  • Simplicité pour faire évoluer vos projets : créer des pipelines en temps réel sans devoir maîtriser chacun des systèmes sous-jacents. Snowflake gère l’infrastructure, son évolution et le pipeline sur l’ensemble de la connectivité, de la transformation et de la mise à disposition. Les fonctionnalités de Snowflake CoCo transforment la configuration du pipeline en une conversation guidée. Décrivez votre besoin : CoCo configure, crée et implémente la logique.
  • Des performances élevées pour un coût total réduit : obtenez des informations récentes sans financer un stack en temps réel entièrement distinct. Votre équipe peut se passer de bases de données de mise à disposition séparées et de stockage dupliqué, ainsi que des efforts d’ingénierie nécessaires pour les exploiter, les surveiller et les dépanner. Lors de nos tests internes, nous avons observé une latence de bout en bout P50 de trois secondes[1] avec Snowpipe Streaming, les transformations en streaming et Snowflake Interactive Analytics.
  • Une gouvernance à chaque étape : découvrir et sécuriser les données et les ressources d’IA, puis créer avec elles dans un environnement intégré. Horizon Catalog centralise dans Snowflake les contrôles d’accès, la traçabilité, la qualité des données et le contexte stratégique. Créer un climat de confiance dans toute votre organisation grâce à la surveillance de la qualité des données et à la classification des données et des ressources d’IA.
Schéma « After » d'une architecture streaming unifiée dans Snowflake. Les sources (applications et services, appareils IoT, topics Kafka, agents IA) alimentent trois étapes. Connect ingère les données en continu via Snowpipe Streaming (API directe, GA) et Datastream (compatible Kafka, préversion publique bientôt). Transform les traite à la fraîcheur requise grâce à Streaming Transformations, des transformations à la volée en préversion privée. Serve les met à disposition des personnes, applications et IA : analytique interactive avec service à faible latence (GA), et tableaux de bord, applications et IA qui partagent les mêmes données. En socle, le catalogue Horizon assure une gouvernance unifiée.
Figure 2 : Snowflake réunit la connexion, la transformation et la mise à disposition des données en temps réel au sein d’un même environnement.

Connecter les données en temps réel sans ajouter d’infrastructure

L’analytique en temps réel commence par une ingestion rapide et simple des données. Snowpipe Streaming achemine les données des applications, appareils et services directement vers les tables natives Snowflake ou les Iceberg Tables. Les équipes peuvent choisir librement le format de table adapté à leur architecture. Les tables natives offrent une solution simple et entièrement gérée pour l’analytique opérationnelle et les applications. Les Iceberg Tables conservent les données dans un format ouvert accessible à d’autres outils. Les données sont interrogeables en quelques secondes, avec un débit de jusqu’à 20 Go/s par table et une tarification fixe basée sur l’ingestion.

L’ingestion est souvent le poste budgétaire qui détermine si un projet en temps réel verra le jour. Lorsque les coûts augmentent avec chaque nouvelle source, les équipes conservent moins de données actualisées qu’elles ne le souhaiteraient. À charge de travail comparable, Snowpipe Streaming est 5 fois moins cher[2] que Zerobus et 80 % moins cher que ClickPipes[3]. Vous payez un tarif fixe basé sur le volume de données ingéré, ce qui garantit des coûts prévisibles à mesure que vous ajoutez des sources.

Pour les équipes des services financiers, chaque seconde compte. Rendre les activités de trading, les historiques de transactions et les événements opérationnels disponibles pour analyse en quelques secondes permet aux équipes d’agir à partir d’informations à jour. Cboe Global Markets illustre l’ampleur de cette approche : l’entreprise utilise Snowpipe Streaming pour charger 190 milliards de lignes par jour en moins de 30 secondes, puis fournit directement ces données aux analystes via des entrepôts interactifs.

À mesure que le volume d’événements augmente, les équipes ne devraient pas consacrer davantage de temps à gérer les mécanismes d’ingestion. Avec les Elastic Channels de Snowpipe Streaming, disponibles pour tous nos clients, des centaines de producteurs, notamment des applications et des appareils Internet des objets (IoT), peuvent écrire vers une même destination par l’intermédiaire d’un canal élastique unique. Vous pouvez connecter davantage de sources sans créer ni gérer de canaux supplémentaires. Snowflake adapte automatiquement le chemin d’ingestion à l’augmentation des volumes. Les événements sont livrés dans l’ordre, une seule fois. Les équipes peuvent ainsi se consacrer à l’analyse plutôt qu’à l’écriture d’une logique de déduplication en aval. Lors de nos tests internes, nous avons encore augmenté le débit pour atteindre 41 Go/s dans une seule table.

Schéma comparant deux chemins d'ingestion de données en streaming vers Snowflake. En haut, un parcours multi-étapes illustratif, dont les composants varient selon la charge de travail. Les producteurs de données (appareils, applications, services) passent par un bus de messages (brokers, partitions), puis par des connecteurs (routage, gestion des schémas), puis par un stockage objet (staging, copies en double), avant d'arriver dans les tables Snowflake. En bas, Snowpipe Streaming Elastic Channels simplifie ce flux : des milliers d'écrivains indépendants envoient leurs données via des canaux élastiques, avec mise à l'échelle automatique et accusé de réception durable, par SDK ou REST. Les données arrivent directement dans des tables Snowflake ou Iceberg, prêtes à être traitées, interrogées et analysées.
Figure 3 : Elastic Channels permet d’ingérer des données en streaming directement dans Snowflake, sans ajouter de système intermédiaire dédié à l’ingestion.

 

De nombreuses équipes utilisent déjà des producteurs et consommateurs Apache Kafka®, mais l’infrastructure de streaming est souvent conçue pour les ingénieurs infrastructure. Datastream, bientôt disponible en public preview et actuellement en private preview, adopte une approche centrée sur les données. Ce service natif Snowflake compatible avec Kafka permet aux équipes data d’utiliser leurs producteurs et consommateurs Kafka existants avec un endpoint géré, sans exploiter de brokers ni maintenir une couche de connecteurs distincte pour transférer les données vers les tables. Le streaming centré sur les données recentre les équipes sur les données gouvernées : elles gèrent les topics, la fraîcheur et les pipelines plutôt que les partitions, la réplication et la capacité du cluster. Des clients comme Minted et Zywave adoptent cette approche pour réduire la multiplication des systèmes d’authentification, des rôles et des outils de surveillance entre Kafka et Snowflake.

Tableau comparatif en deux colonnes sur le streaming de données. À gauche, en orange, l'approche centrée infrastructure telle qu'elle fonctionne aujourd'hui : on part d'un cluster, on raisonne en partitions, réplication et rééquilibrage, il faut configurer un connecteur pour charger les données dans une table, et on monte en charge en redimensionnant le cluster. À droite, en bleu, l'approche centrée données de Datastream : on part d'un topic, traité comme un actif du catalogue, on raisonne en données, fraîcheur et pipelines, le chargement topic-vers-table est intégré, et on monte en charge en allouant un groupe de brokers, comme un entrepôt (warehouse).
Figure 4 : Le streaming centré sur les données transforme le point de départ, la manière d’aborder les projets et les tâches auxquelles les équipes consacrent leur temps.

Transformer les données avec le niveau de fraîcheur dont votre business a besoin

Les données récentes n’ont de valeur qu’une fois adaptées aux besoins du business. En filtrant, enrichissant, restructurant et agrégeant les données entrantes pendant leur ingestion avec Snowpipe Streaming, les transformations en streaming, en private preview, les rendent exploitables pour l’analytique en temps réel. Les équipes définissent la logique une seule fois dans une définition de pipe SQL, puis les enregistrements sont transformés avant d’être chargés dans une table.

Les équipes peuvent éliminer les événements non pertinents, enrichir les enregistrements entrants avec des données de référence, appliquer une logique personnalisée et développer des tableaux imbriqués en lignes individuelles. Intégrer la transformation au chemin d’ingestion simplifie le stack de streaming et accélère l’exploitation des données, comme le constatent déjà plusieurs clients Snowflake. Un fabricant d’équipements industriels standardise les identifiants de ses clients et de ses actifs afin que ses workflows analytiques reçoivent des enregistrements nommés de manière cohérente. Parallèlement, une entreprise de cybersécurité utilise les transformations en streaming pour traiter les événements de sécurité en temps réel et réduire les coûts de traitement ainsi que la latence de la surveillance et du reporting.

Pour les autres charges de travail prises en charge, les transformations en streaming peuvent supprimer le besoin d’une couche externe de traitement des flux, ainsi que celui de créer, planifier et maintenir des transformations en aval après le chargement des données. Résultat : moins d’infrastructure à exploiter et un parcours plus court entre les événements bruts et les informations exploitables. Les transformations en streaming prennent en charge les tables Snowflake standard et interactives, ainsi que les Iceberg Tables gérées par Snowflake. Les objectifs actuels de fraîcheur entre l’ingestion et la mise à disposition sont inférieurs à trois secondes pour les destinations interactives et à 10 secondes pour les destinations standard et Iceberg.

Visuel sur l'enrichissement des données en streaming dans Snowflake. À gauche, trois encadrés présentent les fonctionnalités. In-Stream Join Processing combine en continu les flux temps réel avec des jeux de données de référence existants. Reference Dimension Tables exécute des LEFT OUTER JOIN sur des tables de dimension, comme les profils utilisateurs ou les localisations. Rows Land Enriched charge les enregistrements enrichis directement dans les tables cibles Snowflake, en une seule étape. À droite, le fichier SQL enriched_events_pipe.sql crée un pipe (CREATE PIPE … COPY INTO enriched_events). Il lit une source de données de type 'STREAMING', convertit les champs event_id, event_time, amount et user_id, et effectue des jointures sur les tables dim_users et dim_cities pour ajouter user_name et city.
Figure 5 : Une jointure externe gauche associe le flux entrant aux tables de dimensions de référence afin que les lignes enrichies soient directement chargées dans la table cible.

Fournir des réponses en moins d’une seconde à grande échelle avec Interactive Analytics

C’est souvent dans la dernière ligne droite que les projets en temps réel échouent. Les tableaux de bord, les applications destinées aux clients et les agents d’IA interrogent simultanément les mêmes données. Pour tenir la cadence, les équipes se tournent souvent vers une base de données de mise à disposition distincte. Interactive Analytics prend directement en charge ces charges de travail dans Snowflake.

Lors de tests internes, les entrepôts interactifs ont exécuté des requêtes en moins d’une seconde, avec une concurrence neuf fois supérieure et une latence trois fois inférieure à celles des entrepôts standard. Avec Zero-Copy Interactive, disponible pour tous nos clients, ils s’exécutent directement sur les tables standard, dynamiques et Iceberg Tables existantes. Aucune copie spécialisée n’est nécessaire pour servir les données avec une faible latence. Pour l’ingestion en streaming, nous prenons en charge jusqu’à 41 Go/s par table, et les données deviennent interrogeables en quelques secondes.

Dans deux benchmarks menés par McKnight Consulting Group, à coût de calcul horaire comparable, Snowflake a exécuté 100 % des requêtes à chaque niveau de concurrence testé, jusqu’à 32 utilisateurs simultanés. Sur les requêtes de tableaux de bord, Snowflake a également fourni un débit plus de cinq fois supérieur à celui d’une base de données d’analytique en temps réel leader, tandis que son concurrent a échoué sur 73 % des agrégations à forte cardinalité. Lors d’un troisième test simulant un pic soudain de trafic multiplié par cinq, Snowflake a automatiquement augmenté sa capacité et maintenu 99,997 % des requêtes dans les limites du SLA, avec une latence p99 inférieure de 40 % à celle du concurrent dimensionné pour les pics de charge. Pour égaler les résultats de Snowflake, le concurrent devrait exploiter en permanence une capacité dimensionnée pour les pics, pour un coût annuel presque deux fois supérieur, soit 31 273 USD contre 15 959 USD.

Graphique à barres horizontales comparant les coûts de calcul sur un an : 31 278 dollars pour ClickHouse, contre 15 959 dollars pour Snowflake Interactive XS.
Figure 6. Modélisation du coût de calcul sur un an, avec 52 pics hebdomadaires, sur la base de 3 dollars par crédit Snowflake et de 1,19 dollar par heure-réplique ClickHouse. Seul le calcul est pris en compte ; le stockage est exclu dans les deux cas. Source : https://mcknightcg.com/auto-scaling-for-spiky-workloads-designing-snowflake-for-interactive-analytics/

 

La mise à disposition s’effectue sur les mêmes données gouvernées que celles utilisées par votre business. Il n’y a donc aucune tâche de synchronisation à maintenir ni de deuxième copie à sécuriser. Les équipes stockent les données une seule fois et les servent à partir de cette copie. Les coûts restent ainsi prévisibles à mesure que le volume et la concurrence augmentent.

Par exemple, plutôt que de déployer une plateforme distincte de détection des menaces, Canva a rapproché la détection de ses données. Interactive Analytics exécute chaque minute des milliers de requêtes de détection sur les journaux d’audit en direct et les données de référence fiables que Canva conserve déjà dans Snowflake, sans deuxième copie à maintenir. Lors d’une évaluation représentative d’un environnement de production, l’entrepôt interactif a pris en charge plus de dix fois la charge simultanée d’un entrepôt standard équivalent, pour un coût modélisé nettement inférieur.

Quote Icon

Nous ne voulions pas créer une plateforme supplémentaire ni constituer une équipe pour l’exploiter. Nos données les plus fiables sur notre produit et notre communauté se trouvaient déjà dans Snowflake. Nous avons donc rapproché la détection des données, ce qui a amélioré la fiabilité de nos alertes. »

Calvin Wang
Staff Analytics Engineer, Security Group, Canva

Commencez dès aujourd’hui

Les entreprises ont besoin d’un moyen plus simple de transformer les données récentes en décisions. Snowflake fournit un environnement connecté pour l’analytique en temps réel : simple à exploiter, rapide pour servir les données, économique à faire évoluer, ouvert aux tables natives comme aux Iceberg Tables et gouverné du premier événement à la décision finale. Et Snowflake CoCo facilite la création à chaque étape. Décrivez simplement votre besoin en langage naturel : CoCo peut vous aider à configurer la connectivité, à créer les transformations et à paramétrer Interactive Analytics.

Découvrez comment tous ces éléments s’articulent dans notre webinaire à la demande « Données en temps réel : les fondations de l’IA agentique », dans lequel nous présentons les bonnes pratiques et une architecture de référence pour créer une analytique en temps réel au service des tableaux de bord, des applications et des agents d’IA.


  1.  La latence médiane (P50) de mise à disposition des données, soit 3 secondes, a été mesurée lors de tests internes menés par Snowflake le 20 octobre 2026. Ces tests couvraient l’ensemble du parcours dans Snowpipe Streaming, les transformations en streaming et Interactive Analytics. ↩
  2.  Comparaison des coûts basée sur Snowpipe Streaming à 0,0037 crédit/Go × 2,35 USD/crédit, soit le prix moyen d’un crédit Snowflake, pour un total d’environ 0,0087 USD/Go. Comparé au prix catalogue de Databricks Zerobus, soit 0,05 USD/Go, ce tarif est environ 5,75 fois inférieur, chiffre arrondi à environ 5 fois en moyenne.
  3.  Comparé au tarif publié de ClickPipes pour l’ingestion en streaming, soit 0,04 USD/Go, ce coût est inférieur d’environ 78 %, chiffre arrondi à 80 %. ClickPipes facture également le calcul séparément. Ces frais sont exclus de la comparaison.
Partager ce post

Subscribe to our blog newsletter

Get the best, coolest and latest delivered to your inbox each week

Where Data Does More