Documentation Oracle Cloud Infrastructure

Appel d'Anomaly Detection avec OCI Streaming

Vous pouvez utiliser Anomaly Detection pour détecter les anomalies avec le service OCI Streaming.

Cette combinaison active les données d'entrée dans un flux de service Streaming, puis Anomaly Detection effectue un appel de détection sur ce flux de données, ce qui entraîne le placement des données de sortie dans un autre flux.

Le service OCI Connector Hub est conçu pour connecter différents services ensemble. Lorsque vous utilisez Connector Hub pour connecter Anomaly Detection, Functions et Streaming, vous pouvez concevoir une solution permettant de détecter les anomalies dans les données de transmission en continu. La conception de la solution s'effectue comme suit :

  1. Indiquez un flux de données en entrée à l'aide de Streaming.

  2. Indiquez un flux de données en sortie à l'aide de Streaming.

  3. Créez une fonction en tant que service (FaaS) qui appelle Anomaly Detection.

  4. Créez une autre FaaS qui renvoie les résultats du service Anomaly Detection en tant que sortie de la fonction FaaS.

  5. Enfin, utilisez Connector Hub pour placer la sortie FaaS dans le flux de données.

Montre comment connecter les flux, les fonctions et le connecteur au service de détection des anomalies.

Détection des anomalies dans les données de transmission en continu avec Anomaly Detection

Avant de commencer, vous devez :

  • disposer d'un modèle entraîné prêt à être utilisé pour ce processus. Modifiez les propriétés listées ci-après dans l'exemple de code afin de créer votre application FaaS.

    • endpoint

    • model_id

    • stream_id

    • message_endpoint

    • partition_id

  • vous assurer que vous avez configuré les stratégies du service Anomaly Detection.

  • définir ces stratégies de sorte que le service Functions puisse appeler le service Anomaly Detection :

    1. Créez un groupe dynamique pour la fonction :

      All {resource.compartment.id = <compartment_id>, resource.type = 'fnfunc' }
    2. Ajoutez les droits d'accès suivants pour le groupe dynamique :
      DEFINE dynamic-group AD_SERVICE_CALLING_FUNC as <function_dynamic_group>
ALLOW dynamic-group AD_SERVICE_CALLING_FUNC to use ai-service-anomaly-detection-model in compartment <compartment_name>
Utilisez cette solution pour détecter les anomalies dans les données de transmission en continu :
  1. Créez un flux de données en entrée et un flux de données en sortie dans le service Streaming à l'aide de l'une des méthodes proposées.
  2. Créez l'application qui sera utilisée pour créer la fonction FaaS dans le service Functions.

    Une fois l'application active, vous pouvez lui ajouter une fonction.

  3. Cliquez sur le nom de l'application dans la liste.
  4. Cliquez sur Mise en route pour commencer à créer votre fonction FaaS.
  5. Cliquez sur Configuration locale.
  6. Suivez les instructions pour configurer la fonction FaaS, puis pour l'appeler en remplaçant les valeurs d'environnement par vos propres valeurs.

    Assurez-vous que la fonction FaaS est active avant de continuer.

  7. (Facultatif) Activez la journalisation si vous voulez utiliser les journaux pour déboguer l'option FaaS. Pour ce faire, cliquez sur Journaux, sur le menu Actions (Menu Actions), puis sur Activer le journal et indiquez les éléments suivants :
      • Compartiment : compartiment dans lequel créer le journal. Il s'agit, par défaut, du compartiment en cours.
      • Groupe de journaux : groupe de journaux dans lequel le journal doit être créé. Sélectionnez un groupe de journaux existant ou l'une des options suivantes :
        • Créer automatiquement un groupe de journaux par défaut : permet de créer un groupe de journaux par défaut portant un nom par défaut, s'il n'en existe pas déjà un.
        • Créer un groupe de journaux : permet de créer un groupe de journaux avec un nom et une description que vous fournissez.
      • Nom de journal : nom du nouveau journal. Par défaut, <nom-application>_invoke.
      • Conservation de journal : durée de conservation des données de journal.
    2. Cliquez sur Activer le journal pour créer le journal (et le groupe de journaux, si vous en avez spécifié un).
  8. Créez un connecteur dans Connector Hub à l'aide de l'option Utiliser les paramètres manuels pour configurer la tâche.
    Remarque

    Si vous ne disposez pas des stratégies requises configurées pour créer des connecteurs, cette étape de création vous aide à les configurer.

  9. Indiquez les flux de données en entrée et en sortie avec la tâche qui est la fonction FaaS que vous avez créée.
  10. Cliquez sur Créer pour terminer la configuration.

Désormais, tous les messages envoyés au flux de données en entrée sont transmis au service Anomaly Detection. Les résultats du service Anomaly Detection sont envoyés au flux de données en sortie.