À propos de l'analyse de flux en continu

Créez des tableaux de bord opérationnels personnalisés qui fournissent une surveillance et des analyses en temps réel des flux d'événements à l'aide de l'analyse de flux OCI GoldenGate. Identifier les événements qui vous intéressent, exécuter des interrogations sur les flux d'événements en temps réel ou déclencher des alertes en fonction de votre analyse.

Concepts d'analyse de flux

Commencez par les informations de base. Familiarisez-vous avec les concepts suivants :

  • Connexion : Stocke les informations de connectivité pour une technologie source ou cible.
  • Flux : Flux continu de données dynamiques.
  • Pipeline : Données de flux de travail de la source à la cible.
  • Logique d'affaires : Divers filtres et fonctions que vous pouvez appliquer à un pipeline pour obtenir les données précises à analyser.
  • Publication : rend le pipeline disponible pour tous les utilisateurs d'analyse de flux et envoie des données aux cibles.

Connexions prises en charge

Découvrez les types de connexion pris en charge par OCI GoldenGate Stream Analytics.

OCI GoldenGate Stream Analytics prend en charge les types de technologie source suivants :

Note :

Vous pouvez également créer des connexions Coherence, Ignite et Java Message Server (JMS) directement dans la console Stream Analytics.

Stream Analytics prend en charge les types de technologie cible suivants :

Note :

Vous pouvez également créer des connexions Amazon S3, Azure Data Lake Storage, Coherence, Hadoop File Storage (HDFS), Ignite, JMS et MongoDB directement dans la console Stream Analytics.

Prise en charge et limites de Stream Analytics

Bien que l'analyse de flux OCI GoldenGate s'affiche de la même manière que l'analyse de flux GoldenGate (GGSA), certaines fonctions ne sont disponibles que dans la version OCI et d'autres ne sont pas prises en charge dans la version OCI :

Limites propres à OCI

  • Les fichiers JAR personnalisés ne sont pas pris en charge dans OCI GoldenGate Stream Analytics.
  • L'analyse de flux OCI GoldenGate n'inclut pas de grappe Kafka accessible aux utilisateurs. Pour l'entrée ou la sortie Kafka, y compris l'utilisation de l'entrée de modification de données GoldenGate, un déploiement Kafka distinct, tel que le service de diffusion en continu pour OCI, est requis.

Faites attention aux notes dans l'analyse de flux GoldenGate qui vous indiquent si une fonction est prise en charge ou non dans l'analyse de flux OCI GoldenGate.

Mesures et facturation pour les déploiements Stream Analytics

Assurez-vous de vérifier les informations sous Mesure et facturation pour les déploiements OCI GoldenGate concernant la sélection et l'ajustement des unités Oracle Compute (OCPU).

L'utilisation d'OCPU pour l'analyse de flux pour OCI GoldenGate est calculée en fonction des facteurs suivants :

  • Console Stream Analytics
  • Nombre de pipelines de diffusion en continu
  • Ignorer la grappe
  • Grappe de mégadonnées GoldenGate

Avant de calculer le nombre d'OCPU dont vous avez besoin, examinons d'abord le nombre d'unités de calcul requises par chaque ressource Stream Analytics. 1 OCPU est égale à 2 unités de calcul (vCPUs). 1 unité centrale virtuelle est égale à 1000 millicores (1000m).

Le tableau suivant présente des exemples de paramètres de pipeline Stream Analytics et le nombre calculé d'OCPU requis.
Pipeline Pilote Exécuteur Nombre total d'unités centrales virtuelles OCPU facturées
Ensemble d'opportunités A 500m 1 x 500m 1000m 1
Ensemble d'opportunités B 500m 2 x 500m 1500m 1
Ensemble d'opportunités C 500m 4 x 500m 2500m 2
Ensemble d'opportunités D 600m 2 x 700m 2000m 1
Ensemble d'opportunités E 1000m 2 x 1000m 3000m 2

Vous pouvez configurer les paramètres de pilote et d'exécuteur selon les besoins pour chaque pipeline dans la console Stream Analytics.

Le tableau suivant présente des exemples de configurations de ressources Stream Analytics en fonction du nombre de pipelines (du tableau ci-dessus) et du nombre calculé d'OCPU requis.

Console Stream Analytics Nombre de pipelines Pipelines de diffusion en continu Ignorer la grappe GoldenGate pour la grappe de mégadonnées OCPU facturées
1000m 1 x Pipeline A 1000m 0 0 1
1000m 3 x Pipeline A 3000m 0 0 2
1000m 1 x Pipeline B 1500m 0 0 2
1000m 1 x Pipeline B 1500m 2 x 500m 500m 2
1000m 1 x Pipeline A

1 x Pipeline B

2500m 2 x 500m 500m 3
1000m 2 x Pipeline A

1 x Pipeline B

3500m 2 x 500m 500m 3

La console Stream Analytics requiert 1000m. Chaque pipeline de diffusion nécessite des millicores supplémentaires en fonction de leurs paramètres. Le cluster Ignite, s'il est activé, nécessite un minimum de 2 instances de cluster. Vous pouvez configurer la limite de millisecondes pour les grappes de mégadonnées Ignite et GoldenGate dans la console Stream Analytics. Une fois ajoutés, vous pouvez déterminer le nombre total d'OCPU que vous devez sélectionner lors de la création de votre déploiement Stream Analytics.

Si vous n'êtes pas sûr, vous pouvez commencer par 2 ou 3 OCPU, puis vérifier les mesures de consommation d'OCPU dans la page des détails du déploiement et les ajuster en conséquence.