Partager via

Ajouter une source HTTP à un flux d’événements (préversion)

Cet article explique comment ajouter une source HTTP à un flux d’événements.

Le connecteur HTTP fournit un moyen sans code configurable de diffuser en continu des données à partir d’une API REST directement dans Eventstream pour le traitement en temps réel. Il vous permet d’extraire en continu des données à partir de plateformes SaaS et de flux de données publics et d’analyser automatiquement les réponses JSON dans des événements structurés. Il propose également des exemples de flux publics pour vous aider à commencer rapidement : il vous suffit de sélectionner un exemple d’API, d’entrer votre clé d’API et de laisser Eventstream préremplir les en-têtes et paramètres requis.

Prerequisites

  • Un espace de travail avec une capacité Fabric ou un mode de licence d’essai .
  • Accès à l’espace de travail avec le rôle Contributeur ou des rôles supérieurs.
  • Si vous n’avez pas de flux d’événements, suivez le guide pour créer un flux d’événements.

Ajouter HTTP en tant que source

Si vous n’avez pas encore ajouté de source à votre flux d’événements, sélectionnez la vignette Utiliser la source externe .

Capture d’écran montrant la sélection de la vignette pour l’utilisation d’une source externe.

Si vous ajoutez la source à un flux d’événements déjà publié, basculez vers le mode Modifier. Dans le ruban, sélectionnez Ajouter> dessources externes.

Capture d’écran montrant les sélections pour l’ajout de sources externes.

Recherchez http, puis sélectionnez Connecter pour ajouter le connecteur HTTP à votre flux d’événements.

Capture d’écran montrant la sélection de HTTP comme type de source dans l’Assistant Sélectionner une source de données.

Configurer et se connecter à HTTP

Vous pouvez sélectionner l’un des exemples d’API publiques pour commencer rapidement avec des en-têtes et des paramètres prédéfinis, ou sélectionner Quitter pour configurer votre propre connecteur HTTP personnalisé.

Utiliser des exemples d’API publiques

  1. Sélectionnez un exemple d’API publique pour configurer rapidement le connecteur HTTP : capture d’écran montrant un exemple de page d’API.

    • Binance. Obtenir le dernier prix de Bitcoin
    • CoinGecko. Obtenir le prix actuel de Bitcoin en USD
    • Transport pour Londres. Obtenir des prédictions d’arrivée en direct pour une gare de Londres
    • Alpha Vantage. Obtenir le prix des actions MSFT en temps réel
    • OpenWeather. Obtenir les prévisions météorologiques d’un emplacement
    • NewsAPI. Obtenez les dernières actualités commerciales aux États-Unis

  2. Pour les API qui nécessitent une clé API, utilisez le lien fourni pour appliquer la clé API et entrez-la dans la zone d’entrée. Le connecteur crée ensuite automatiquement la connexion cloud Fabric et prérempli les en-têtes et paramètres HTTP requis.

    Important

    L’exemple d’API Binance ne nécessite pas de clé API, mais vous êtes responsable de la conformité à ses conditions d’utilisation.

  3. Si vous choisissez Utiliser une connexion existante, sélectionnez Appliquer l’exemple pour préremplir les en-têtes et paramètres requis pour l’EXEMPLE d’API sans entrer de clé API.

  4. Vous pouvez également sélectionner Quitter pour fermer la fenêtre et configurer votre propre source HTTP à partir de zéro.

Configurer votre propre source HTTP

Suivez les étapes pour configurer votre propre source HTTP sans exemple d’API.

  1. Créez une connexion. Sélectionnez Nouvelle connexion et entrez les propriétés requises pour votre source HTTP :

    Capture d’écran montrant où sélectionner la nouvelle page de connexion.

    • URL de base : URL de base du point de terminaison HTTP.
    • Uri d’audience de jeton (facultatif) : ressource pour laquelle le jeton est destiné.
    • Nom de la connexion : saisissez un nom pour la connexion.
    • Type d’authentification : Actuellement, le connecteur HTTP prend uniquement en charge Anonymous, Basicet API Key l’authentification.

    Capture d’écran montrant la nouvelle page de connexion.

  2. Méthode de requête : Sélectionner GET ou POST.

  3. En-têtes et paramètres : si vous avez sélectionné l’authentification de clé API lorsque vous avez créé la connexion cloud, utilisez le paramètre dynamique ${apiKey} dans vos en-têtes ou paramètres pour référencer la clé API.

    Par exemple, pour vous connecter à CoinGecko, utilisez l’en-tête : x_cg_demo_api_key = ${apiKey}.

    Important

    N’entrez pas votre clé API ou d’autres informations d’identification dans les en-têtes ou les paramètres.

  4. Intervalle de requête (s) : spécifie le temps en secondes d’attente entre les requêtes consécutives ; la plage valide est [1, 3600].

  5. Nombre maximal de nouvelles tentatives : nombre maximal de tentatives du connecteur lors d’une erreur ; la plage valide est [10, 100].

  6. Nouvelle tentative d’interruption (s) : temps en secondes pour attendre après une erreur avant que le connecteur ne retente ; la plage valide est [1, 3600].

  7. Code d’état de nouvelle tentative : les codes d’erreur HTTP retournés qui invitent le connecteur à réessayer la requête. Entrez une liste séparée par des virgules de codes ou de plages de codes. Les plages sont spécifiées avec un code de début et de fin facultatif. Par exemple:

    • 400- inclut tous les codes supérieurs ou égaux à 400.
    • 400-500 inclut des codes compris entre 400 et 500, y compris 500.
    • 404,408,500- invite le connecteur à réessayer sur 404 NOT FOUND, 408 REQUEST TIMEOUT et tous les codes d’erreur 5xx.

    Certains codes d’état sont systématiquement retentés, tels que non autorisé, délai d'attente, et trop de requêtes.

    Capture d’écran montrant les paramètres configurés.

  8. Passez en revue le résumé de configuration de la source HTTP, puis sélectionnez Ajouter.

    Capture d’écran montrant la page de configuration de révision.

Vous pouvez voir la source HTTP ajoutée à votre flux d’événements en mode Édition.

Capture d’écran de la source HTTP ajoutée en mode Édition avec le bouton Publier mis en surbrillance.

Sélectionnez Publier pour publier les modifications et commencer la diffusion de données à partir de la source HTTP vers le flux d’événements.

Capture d’écran de la source HTTP ajoutée en mode Live avec le bouton Publier mis en surbrillance.

Limitation

  • Le connecteur HTTP prend actuellement en charge uniquement les réponses d’API JSON .
  • L’authentification OAuth n’est pas prise en charge.
  • La source HTTP ne prend pas en charge les fonctionnalités CI/CD, notamment l’intégration Git et le pipeline de déploiement. L’exportation ou l’importation d’un élément Eventstream qui inclut cette source via Git peut entraîner des erreurs.

Contenu connexe

Autres connecteurs :

  • Last updated on