Hinzufügen einer HTTP-Quelle zu einem Eventstream (Vorschau)

In diesem Artikel wird gezeigt, wie Sie einem Eventstream eine HTTP-Quelle hinzufügen.

Der HTTP-Connector bietet eine codefreie, konfigurierbare Möglichkeit zum Streamen von Daten aus einer beliebigen REST-API direkt in Eventstream zur Echtzeitverarbeitung. Sie können kontinuierlich Daten von SaaS-Plattformen und öffentlichen Datenfeeds abrufen und JSON-Antworten automatisch in strukturierte Ereignisse analysieren. Es bietet auch Beispiel-öffentliche Feeds, die Ihnen helfen, schnell zu beginnen, eine Beispiel-API auszuwählen, Ihren API-Schlüssel einzugeben und Eventstream die erforderlichen Header und Parameter vorab ausfüllen zu lassen.

Voraussetzungen

  • Ein Arbeitsbereich mit Fabric-Kapazität oder einem Arbeitsbereichstyp Fabric Testversion.
  • Zugriff auf den Arbeitsbereich mit Mitwirkenden - oder höheren Arbeitsbereichsrollen.
  • Ein HTTP-Endpunkt, der öffentlich zugänglich ist. Wenn es sich in einem geschützten Netzwerk befindet, stellen Sie mithilfe der Eventstream Connector virtual network Injection eine Verbindung mit ihr her.

Hinzufügen von HTTP als Quelle

Wenn Sie Ihrem Eventstream noch keine Quelle hinzugefügt haben, wählen Sie die Kachel "Datenquellen verbinden" aus . Sie können auch Quelle hinzufügen>Datenquellen verbinden im Menüband auswählen.

Screenshot, der die Auswahl der Kachel zum Verwenden einer externen Quelle zeigt.

Wenn Sie die Quelle zu einem bereits veröffentlichten Ereignisstream hinzufügen, wechseln Sie zum Bearbeitungsmodus . Wählen Sie im Menüband "Quelle hinzufügen; Datenquellen verbinden" aus.

Screenshot der Auswahl zum Hinzufügen externer Quellen.

Suchen Sie nach http, und wählen Sie "Verbinden" aus, um den HTTP-Connector zu Ihrem Eventstream hinzuzufügen.

Screenshot, der die Auswahl von HTTP als Quelltyp im Assistenten zum Auswählen einer Datenquelle zeigt.

Konfigurieren und Herstellen einer Verbindung mit HTTP

Sie können eine der öffentlichen Beispiel-APIs auswählen, um schnell mit vordefinierten Headern und Parametern zu beginnen, oder "Beenden" auswählen, um Ihren eigenen benutzerdefinierten HTTP-Connector zu konfigurieren.

Beispiel für öffentliche APIs verwenden

  1. Wählen Sie ein Beispiel für eine öffentliche API aus, um den HTTP-Connector schnell einzurichten: Screenshot der Beispiel-API-Seite.

    • Binance. Holen Sie sich den neuesten Bitcoin-Preis
    • CoinGecko. Abrufen des aktuellen Bitcoin-Preises in USD
    • Transport für London. Erhalten Sie Live-Ankunftsvorhersagen für eine London Station
    • Alpha Vantage. Microsoft (MSFT)-Aktienkurs in Echtzeit abrufen
    • OpenWeather. Abrufen der Wettervorhersage für einen Standort
    • NewsAPI. Holen Sie sich die neuesten Geschäftlichen Schlagzeilen in den USA

  2. Verwenden Sie für APIs, die einen API-Schlüssel erfordern, den bereitgestellten Link, um den API-Schlüssel anzuwenden, und geben Sie ihn in das Eingabefeld ein. Der Connector erstellt dann automatisch die Fabric Cloudverbindung und füllt die erforderlichen HTTP-Header und Parameter vor.

    Von Bedeutung

    Für die Binance-Beispiel-API ist kein API-Schlüssel erforderlich, Sie sind jedoch dafür verantwortlich, die Nutzungsbedingungen einzuhalten.

  3. Wenn Sie " Vorhandene Verbindung verwenden" auswählen, wählen Sie " Beispiel anwenden" aus, um die erforderlichen Header und Parameter für die Beispiel-API vorzufüllen, ohne einen API-Schlüssel einzugeben.

  4. Alternativ können Sie "Beenden" auswählen, um das Fenster zu schließen und Ihre eigene HTTP-Quelle von Grund auf neu zu konfigurieren.

Konfigurieren Ihrer eigenen HTTP-Quelle

Führen Sie die Schritte aus, um Ihre eigene HTTP-Quelle ohne Beispiel-API zu konfigurieren.

  1. Erstellen einer neuen Verbindung Wählen Sie "Neue Verbindung" aus, und geben Sie die erforderlichen Eigenschaften für Ihre HTTP-Quelle ein:

    Screenshot, der zeigt, wo die neue Verbindungsseite ausgewählt werden soll.

    • Basis-URL: Die Basis-URL des HTTP-Endpunkts.
    • Token Audience URI (optional):Die Ressource, für die das Token vorgesehen ist.
    • Verbindungsname: Geben Sie einen Namen für die Verbindung ein.
    • Authentifizierungsart: Derzeit unterstützt der HTTP-Connector nur Anonymous, Basic, und API Key-Authentifizierung.

    Screenshot der neuen Verbindungsseite.

  2. Request-Methode: Auswählen GET oder POST.

  3. Header und Parameter: Wenn Sie die API-Schlüsselauthentifizierung beim Erstellen der Cloudverbindung ausgewählt haben, verwenden Sie den dynamischen Parameter ${apiKey} in Ihren Headern oder Parametern, um auf den API-Schlüssel zu verweisen.

    Um beispielsweise eine Verbindung mit CoinGecko herzustellen, verwenden Sie die Kopfzeile: x_cg_demo_api_key = ${apiKey}.

    Von Bedeutung

    Geben Sie nicht Ihren API-Schlüssel oder andere Anmeldeinformationen in die Header oder Parameter ein.

  4. Anforderungsintervall (s): Gibt die Zeit in Sekunden an, die zwischen aufeinander folgenden Anforderungen gewartet werden soll; Gültiger Bereich ist [1, 3600].

  5. Maximale Wiederholungsversuche: Die maximale Anzahl der Wiederholungen, mit denen der Connector eine Anforderung wiederholt, wenn ein Fehler auftritt; Gültiger Bereich ist [10, 100].

  6. Retry-Backoff (s): Die Zeit in Sekunden, die nach einem Fehler gewartet wird, bevor der Connector einen erneuten Versuch unternimmt; gültiger Bereich ist [1, 3600].

  7. Statuscode für erneute Versuche: Die zurückgegebenen HTTP-Fehlercodes, die den Connector veranlassen, die Anfrage erneut zu senden. Geben Sie eine durch Trennzeichen getrennte Liste von Codes oder Codebereichen ein. Bereiche werden mit Start- und optionalem Endcode angegeben. Beispiel:

    • 400- enthält alle Codes, die größer oder gleich 400 sind.
    • 400-500 enthält Codes von 400 bis 500, einschließlich 500.
    • 404,408,500- veranlasst den Connector, bei 404 NICHT GEFUNDEN, 408 REQUEST TIMEOUT und allen 5xx-Fehlercodes einen erneuten Versuch zu starten.

    Einige Statuscodes werden immer erneut versucht, z. B. nicht autorisiert, Timeouts und zu viele Anfragen.

    Screenshot der konfigurierten Einstellungen.

Stream- oder Quelldetails

  1. Führen Sie auf der Seite "Verbinden " einen dieser Schritte aus, je nachdem, ob Sie Eventstream oder Real-Time Hub verwenden.

    • Eventstream:

      Führen Sie im Bereich " Quelldetails " rechts die folgenden Schritte aus:

      1. Wählen Sie für den Quellnamen die Stiftschaltfläche aus, um den Namen zu ändern.

      2. Beachten Sie, dass der Eventstream-Name und der Stream-Name nur zum Lesen sind.

    • Real-Time Hub:

      Führen Sie im Abschnitt Datenstromdetails die folgenden Schritte aus:

      1. Wählen Sie den arbeitsbereich Fabric aus, in dem Sie den Ereignisstream erstellen möchten.

      2. Wählen Sie für den Eventstream-Namen die Stiftschaltfläche aus, und geben Sie einen Namen für den Eventstream ein.

      3. Der Wert für den Stream-Namen wird automatisch generiert, indem "-stream " an den Namen des Ereignisstreams angefügt wird. Dieser Datenstrom wird auf der Seite "Alle Datenströme" des Echtzeithubs angezeigt, wenn der Assistent beendet wird.

  2. Wählen Sie unten auf der Seite "Konfigurieren" die Option "Weiter" aus.

Überprüfen und Verbinden

Überprüfen Sie auf dem Bildschirm "Überprüfen + Verbinden " die Zusammenfassung, und wählen Sie "Hinzufügen " (Eventstream) oder "Verbinden " (Real-Time Hub) aus.

Die HTTP-Quelle, die Ihrem Eventstream hinzugefügt wurde, wird im Bearbeitungsmodus angezeigt.

Screenshot der hinzugefügten HTTP-Quelle im Bearbeitungsmodus mit hervorgehobener Schaltfläche

Wählen Sie "Veröffentlichen" aus, um die Änderungen zu veröffentlichen und mit dem Streaming von Daten aus der HTTP-Quelle in den Eventstream zu beginnen.

Screenshot der hinzugefügten HTTP-Quelle in der Liveansicht mit hervorgehobener Schaltfläche

Einschränkungen

  • Der HTTP-Connector unterstützt derzeit nur JSON-API-Antworten .
  • OAuth-Authentifizierung wird nicht unterstützt.
  • Die HTTP-Quelle unterstützt keine CI/CD-Features, einschließlich Git-Integrations - und Bereitstellungspipeline. Das Exportieren oder Importieren eines Eventstream-Elements, das diese Quelle über Git enthält, kann zu Fehlern führen.

Verwandte Inhalte

Andere Steckverbinder:

  • Last updated on