Tous les produits
Search
Centre de documentation

Realtime Compute for Apache Flink:Présentation de Realtime Compute for Apache Flink

Dernière mise à jour :Aug 09, 2026

Realtime Compute for Apache Flink est une plateforme entièrement gérée et sans serveur permettant de créer des pipelines de données en temps réel et des applications de traitement de flux sur Alibaba Cloud.

Vue d'ensemble

Realtime Compute for Apache Flink s'appuie sur Apache Flink et élimine la charge opérationnelle liée à la configuration du cluster, à la gestion des versions et au réglage des ressources. Vous bénéficiez des avantages suivants :

  • Aucune infrastructure à gérer — aucun cluster à approvisionner, à patcher ou à mettre à l'échelle manuellement.

  • Mise à l'échelle automatique toujours activeAutopilot surveille en continu vos jobs et ajuste l'allocation des ressources pour gérer automatiquement les variations de débit, la contre-pression et le gaspillage de ressources.

  • Tolérance aux pannes automatique — la récupération après incident de bout en bout et la haute disponibilité de JobManager sont intégrées, éliminant ainsi les points de défaillance uniques.

Le service offre une latence inférieure à la seconde et, grâce à l'optimisation des opérateurs SQL et au GeminiStateBackend développé en interne, affiche des performances deux fois supérieures à celles d'Apache Flink open source lors des tests de référence Nexmark.

Cas d'utilisation

  • Pipelines ETL et CDC en temps réel — synchronisez des bases de données entières vers des entrepôts de données ou des data lakes en utilisant Create Database As Select (CDAS) ou Create Table As Select (CTAS), avec une prise en charge native de l'évolution du schéma et de Change Data Capture (CDC).

  • Détection de fraude et d'anomalies — appliquez des règles de traitement complexe d'événements (CEP) sur des flux d'événements à fort volume pour identifier des modèles en temps réel.

  • Tableaux de bord analytiques en temps réel — écrivez du code Flink SQL pour agréger les données en flux continu et pousser les résultats vers Hologres, ClickHouse ou d'autres systèmes en aval avec une actualisation inférieure à la seconde.

  • Pipelines de données alimentés par l'IA — intégrez le prétraitement des données en flux continu aux workflows d'analyse intelligente des données et IA.

  • Surveillance des processus métier — suivez l'exécution des commandes, le statut de livraison ou l'activité client en traitant les flux d'événements avec des alertes basées sur des règles et des notifications via DingTalk ou e-mail.

Comparaison avec Apache Flink

Realtime Compute for Apache Flink est entièrement compatible avec les API et les connecteurs d'Apache Flink, ce qui permet de migrer les charges de travail existantes sans modifier le code. Le tableau ci-dessous résume les principales différences.

Domaine

Apache Flink

Realtime Compute for Apache Flink

Avantages

Performances et coûts

  • Aucune évolutivité élastique native.

  • L'utilisation des ressources dépend d'un réglage manuel.

  • Des performances doublées par rapport à Apache Flink dans les tests de référence Nexmark, grâce à l'optimisation des opérateurs SQL et à GeminiStateBackend.

  • Autopilot surveille et ajuste automatiquement l'allocation des ressources des jobs, résolvant les goulots d'étranglement du débit, la contre-pression dans l'ensemble du pipeline et le gaspillage de ressources sans intervention manuelle.

  • Une configuration granulaire du processeur/mémoire au niveau de l'opérateur améliore l'utilisation des ressources jusqu'à 100 % pour les jobs à grande échelle.

  • Facturation flexible : Abonnement, Paiement à l'utilisation et Facturation hybride pour la consommation d'unités de calcul (CU).

  • Réduction des coûts grâce à une mise à l'échelle intelligente des CU et à des modèles de facturation flexibles.

Compatibilité et intégration

  • API natives Flink SQL et DataStream.

  • Intégration manuelle avec des systèmes tels que MySQL, Apache Kafka et Paimon ; les mises à jour fréquentes des versions peuvent entraîner des problèmes de compatibilité.

  • Entièrement compatible avec les API SQL, DataStream, PyFlink et Flink CDC.

  • Plus de 30 connecteurs intégrés couvrant les bases de données, les files d'attente de messages, les entrepôts de données, les data lakes et les systèmes de fichiers, notamment MySQL, Apache Kafka, Hologres et Paimon.

  • Connecteurs personnalisés pris en charge pour l'intégration avec des systèmes externes.

  • Barrière à l'entrée plus faible et migration plus fluide pour les charges de travail Flink existantes.

Développement et débogage

  • Absence de plateforme de gestion du développement tout-en-un.

  • Outils de débogage limités.

  • Itération plus rapide du développement à la production avec des coûts de débogage réduits.

Opérations et gestion

  • Aucune surveillance ni alerte complète intégrée.

  • Aucune interface utilisateur graphique (GUI).

  • Mise à l'échelle manuelle des ressources avec une planification complexe.

  • Charge opérationnelle réduite grâce à une meilleure observabilité des jobs.

Stabilité et fiabilité

  • Le déploiement du cluster présente des limitations régionales.

  • La tolérance aux pannes doit être configurée manuellement.

  • Haute disponibilité inter-zones sur plusieurs régions.

  • La tolérance aux pannes automatique de bout en bout et la haute disponibilité de JobManager éliminent les points de défaillance uniques.

  • Gestion des checkpoints et des savepoints avec vérifications de compatibilité de l'état et prise en charge de la migration des données.

Fiabilité de niveau entreprise pour les jobs de production à grande échelle.

Support entreprise

  • S'appuie sur la documentation d'Apache Flink et le support communautaire.

  • Aucune équipe de support technique dédiée.

  • Support technique professionnel 24h/24 et 7j/7 fourni par les ingénieurs de Realtime Compute for Apache Flink, avec un SLA de 99,9 %.

  • Réponse rapide, prise en charge de fonctionnalités personnalisées, mises à jour continues et maintenance des versions à long terme.

Résolution plus rapide des incidents et service fiable pour les déploiements en production.

Sécurité et contrôle d'accès

  • Mécanismes d'authentification de base tels que Kerberos.

  • Le contrôle d'accès nécessite une intégration avec des systèmes externes.

  • Contrôle d'accès basé sur les rôles (RBAC) d'Alibaba Cloud.

  • Isolation des ressources et des fichiers de code au niveau du locataire et du projet pour la collaboration inter-équipes.

  • Sécurité des identifiants grâce à la gestion des variables.

  • Audit complet des actions couvrant toutes les modifications de l'environnement de production.

Gestion unifiée des identités et des accès pour la sécurité des données et la conformité.

Extensibilité et écosystème

  • Étend les fonctionnalités via des plug-ins.

  • L'écosystème dépend de la communauté Apache Flink.

  • Prend en charge les cas d'utilisation émergents, notamment l'analyse intelligente des données et l'IA.

  • Prend en charge l'intégration avec les data lakes (Iceberg, Hudi) et les entrepôts de données (ClickHouse, Hologres, MaxCompute).

  • SDK et API RESTful pour le développement secondaire.

Une plateforme flexible et extensible pour divers cas d'utilisation en temps réel.

Facturation

Realtime Compute for Apache Flink comprend deux éléments facturables : les ressources de gestion et les ressources de calcul.

Trois méthodes de facturation sont disponibles :

  • Abonnement : réservez des ressources dédiées pour une période fixe.

  • Paiement à l'utilisation : payez uniquement ce que vous utilisez.

  • Facturation hybride : combinez des ressources d'abonnement réservées avec une capacité élastique de paiement à l'utilisation.

Pour plus de détails, consultez la rubrique Facturation.

Étapes suivantes