Vue d'ensemble (StreamInsight)
Microsoft StreamInsight fournit une plate-forme puissante pour le développement et le déploiement d'applications de traitement des événements complexes (CEP). CEP est une technologie pour le traitement de flux d'événements haut débit à latence faible. Les données des sources de flux d'événements par défaut proviennent de programmes de fabrication, d'applications financières, de services d'analyse Web ou d'analyse opérationnelle. L'architecture de traitement de flux de StreamInsight et la plateforme de développement familière basée sur Microsoft .NET donnent les moyens aux développeurs d'implémenter rapidement des applications de traitement d'événements à la fois robustes et performantes.
StreamInsight présente les avantages suivants :
Performances et débit de données hautement optimisés
StreamInsight implémente une architecture de flux légère qui prend en charge l'exécution parallèle de requêtes continues sur des données haut débit. L'utilisation de caches en mémoire et le calcul de résultat incrémentiel fournissent d'excellentes performances avec les données haut débit et à latence faible. La latence faible est obtenue parce que les événements sont traités sans charge de données onéreuse ou opérations de stockage dans le chemin d'accès de traitement critique. Avec StreamInsight, tout le traitement est déclenché automatiquement par les événements entrants. En particulier, les applications n'ont pas à supporter de surcharge pour l'interrogation des événements. La plateforme fournit les fonctionnalités pour la gestion d'événements non ordonnés. De plus, les données de référence statique ou les données d'historique sont accessibles et incluses dans l'analyse à latence faible.
Environnement de développement .NET
Les développeurs peuvent écrire leurs applications CEP à l'aide du langage .NET de Microsoft, tel que Visual C#, en tirant parti du LINQ de la plateforme de langage évolué (Language Integrated Query) comme un langage de requête incorporé. Étant donné la grande communauté de développeurs déjà familiarisés avec ces technologies, cette fonctionnalité réduit les coûts de développement et le temps nécessaire entre le développement d'applications et la production. Dans la version actuelle, StreamInsight prend en charge uniquement C# comme langage hôte.
En utilisant LINQ, les développeurs familiarisés avec SQL seront en mesure d'écrire rapidement des requêtes déclaratives qui traitent et mettent en corrélation des données de plusieurs flux de données dans des résultats pertinents. L'optimiseur et le planificateur du serveur StreamInsight vérifient ensuite les performances optimales des requêtes.
Fonctionnalité de déploiement flexible
StreamInsight prend en charge trois scénarios de déploiement :
Entièrement intégré dans l'application comme une DLL hébergée (incorporée).
Comme un serveur autonome avec plusieurs applications et utilisateurs qui partagent le serveur. Dans sa configuration autonome, le serveur StreamInsight s'exécute dans un wrapper, tel qu'un fichier exécutable, ou bien le serveur peut être inséré comme un Service Windows.
Le serveur StreamInsight hébergé ou autonome peut faire partie d'une batterie de serveurs.
Simplicité de gestion
Les fonctionnalités d'analyse et de gestion intégrées au serveur StreamInsight assurent un faible coût total de possession (TCO) des applications CEP. L'interface de gestion et les vues de diagnostic fournies sur le serveur StreamInsight permettent à l'administrateur d'analyser et de gérer l'application CEP. L'infrastructure de gestion permet aussi aux ISV et intégrateurs de système d'analyser à distance et de prendre en charge des systèmes déployés par StreamInsight dans des installations de fabrication et d'autres installations montées en charge.
StreamInsight fournit un débogueur de flux d'événements autonome qui peut être utilisé pour analyser, diagnostiquer et résoudre les problèmes des requêtes utilisées dans les applications StreamInsight.
Scénarios CEP
La nécessité d'un traitement de flux d'événements haut débit à latence faible est commune aux scénarios d'application professionnelle suivants :
Analyse de processus de fabrication et contrôle
Analyse des parcours de visite
Services financiers
Services publics
Soins médicaux
Analyse informatique
Logistique
Télécommunications
Les sections suivantes traitent de quelques-uns de ces scénarios et étudient leurs spécifications pour le traitement des événements.
Analyse de processus de fabrication et contrôle
Pour vérifier que les produits et processus s'exécutent de façon optimale et avec le moins de temps mort possible, les usines requièrent des capacités de collecte de données et d'analyse des périphériques et capteurs par usine et par étage, avec une faible latence. Le scénario de fabrication par défaut inclut les spécifications suivantes :
Analyse basée sur les ressources et l'agrégation des données par ordinateur.
Observation basée sur les capteurs des activités par usine et étage et sortie.
Observation et réaction via des contrôleurs de périphérique.
Capacité de gérer au maximum 10 000 événements de données par seconde.
Événement et génération d'alerte en cas de problème.
Maintenance proactive basée sur des conditions sur le matériel clé.
Analyse à faible latence de données agrégées (fenêtrées et échelles logarithmiques).
Analyse des parcours de visite
Une expérience client optimale d'un site Web commercial requiert le traitement à latence faible du comportement de l'utilisateur et des interactions sur le site. L'application d'analyse des parcours de visite par défaut inclut les spécifications suivantes :
Capacité de piloter la mise en page, la navigation et la présentation en fonction de l'analyse des parcours de visite à latence faible.
Capacité de gérer au maximum 100 000 événements de données par seconde pendant les heures de pointe du trafic.
Identification de modèles de flux de données de clic et réponse immédiates avec une campagne de publicité ciblée.
Échange algorithmique dans un environnement de services financiers
L'échange algorithmique, avec ses besoins en traitement de données à fort volume, a en général les spécifications suivantes :
Capacité de gérer au maximum 100 000 événements de données par seconde.
Traitement des requêtes limité dans le temps.
Analyse et capitalisation dans les conditions de marché actuelles avec des fenêtres très courtes d'opportunité.
Filtrage intelligent des données d'entrée.
Capacité de définir des modèles sur plusieurs sources de données et de déclencher automatiquement, dans le temps, les décisions de vente/achat/attente pour l'actif d'un portefeuille.
Services publics
Le secteur public requiert une infrastructure efficace pour la gestion des grilles électriques et d'autres services. Ces systèmes ont en général les spécifications suivantes.
Réponse immédiate aux variations de consommation d'énergie ou d'eau, pour réduire ou éviter les coupures de courant ou pénuries d'eau ou d'autres interruptions de service.
Obtention de rendements opérationnels et environnementaux en adoptant des grilles intelligentes.
Plusieurs niveaux d'agrégation le long de la grille.
Capacité de gérer un maximum de 100 000 événements par seconde issus de millions de sources de données.