Tous les produits
Search
Centre de documentation

Realtime Compute for Apache Flink:Qu'est-ce que Realtime Compute for Apache Flink ?

Dernière mise à jour :Sep 18, 2026

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

Présentation

Realtime Compute for Apache Flink s'exécute sur Apache Flink et élimine la charge opérationnelle liée à la configuration des clusters, à la gestion des versions et à l'ajustement des ressources. Vous bénéficiez des avantages suivants :

  • Aucune infrastructure à gérer — nul besoin de provisionner, patcher ou mettre à l'échelle manuellement les clusters.

  • Mise à l'échelle automatique permanente — Autopilot 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é du JobManager sont intégrées, ce qui élimine les points de défaillance uniques.

Le service offre une latence inférieure à la seconde. Grâce à l'optimisation des opérateurs SQL et au backend d'état propriétaire GeminiStateBackend, il 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 lacs de données avec l'ingestion de données Flink CDC, qui prend nativement en charge l'évolution du schéma et la capture des données modifiées (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 à haut 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 streaming et pousser les résultats vers Hologres, ClickHouse ou d'autres systèmes en aval avec une fraîcheur des données inférieure à la seconde.

  • Pipelines de données alimentés par l'IA — intégrez le prétraitement des données en streaming 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 des 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 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 mise à l'échelle élastique intégrée.

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

  • Des performances deux fois supérieures à celles d'Apache Flink lors des 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 goulets d'étranglement de débit, la contre-pression dans l'ensemble du pipeline et le gaspillage de ressources sans intervention manuelle.

  • Une configuration fine du CPU et de la 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 Flink SQL et DataStream natives.

  • 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 lacs de données et les systèmes de fichiers, y compris 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

  • Aucune 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 aucune alerte intégrées complètes.

  • Aucune interface utilisateur graphique (GUI).

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

  • Charge opérationnelle réduite avec une meilleure observabilité des jobs.

Stabilité et fiabilité

  • Le déploiement de 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é du 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 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 Realtime Compute for Apache Flink, garanti par 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) 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 via 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, y compris l'analyse intelligente des données et l'IA.

  • Prend en charge l'intégration avec les lacs de données (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 comporte 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