Udostępnij przez

Dodawanie źródła HTTP do strumienia zdarzeń (wersja zapoznawcza)

W tym artykule pokazano, jak dodać źródło HTTP do strumienia zdarzeń.

Łącznik HTTP zapewnia konfigurowalny sposób bez kodu na przesyłanie strumieniowe danych z dowolnego interfejsu API REST bezpośrednio do Eventstream do przetwarzania w czasie rzeczywistym. Umożliwia ona ciągłe ściąganie danych z platform SaaS i publicznych źródeł danych oraz automatyczne analizowanie odpowiedzi JSON w zdarzenia strukturalne. Oferuje również przykładowe publiczne źródła danych, które ułatwiają szybkie rozpoczęcie pracy — po prostu wybierz przykładowy interfejs API, wprowadź klucz interfejsu API i pozwól usłudze Eventstream wstępnie wypełnić wymagane nagłówki i parametry.

Wymagania wstępne

  • Obszar roboczy z pojemnością Fabric lub trybem licencji próbnej.
  • Dostęp do obszaru roboczego z rolą Kontrybutora lub wyższą.
  • Jeśli nie masz strumienia zdarzeń, postępuj zgodnie z przewodnikiem, aby utworzyć strumień zdarzeń.

Dodawanie protokołu HTTP jako źródła

Jeśli jeszcze nie dodano żadnego źródła do strumienia zdarzeń, wybierz kafelek Użyj źródła zewnętrznego .

Zrzut ekranu przedstawiający wybór kafelka do korzystania z zewnętrznego źródła.

Jeśli dodajesz źródło do już opublikowanego strumienia zdarzeń, przełącz się na tryb edycji. Na wstążce wybierz pozycję Dodaj źródła>zewnętrzne.

Zrzut ekranu przedstawiający opcje dodawania źródeł zewnętrznych.

Wyszukaj HTTP i wybierz Połącz, aby dodać konektor HTTP do strumienia zdarzeń.

Zrzut ekranu przedstawiający wybór protokołu HTTP jako typ źródła w kreatorze wyboru źródła danych.

Konfigurowanie i nawiązywanie połączenia z protokołem HTTP

Możesz wybrać jeden z przykładowych publicznych interfejsów API , aby szybko rozpocząć pracę ze wstępnie zdefiniowanymi nagłówkami i parametrami, lub wybrać pozycję Zakończ , aby skonfigurować własny niestandardowy łącznik HTTP.

Użyj przykładowych publicznych interfejsów API

  1. Wybierz przykładowy publiczny interfejs API, aby szybko skonfigurować łącznik HTTP: zrzut ekranu przedstawiający przykładową stronę interfejsu API.

    • Binance. Pobierz najnowszą cenę bitcoina
    • CoinGecko. Pobierz bieżącą cenę bitcoina w USD
    • Transport do Londynu. Uzyskiwanie przewidywań przyjazdu na żywo dla stacji w Londynie
    • Alfa Vantage. Uzyskiwanie ceny akcji MSFT w czasie rzeczywistym
    • OpenWeather. Pobieranie prognozy pogody dla lokalizacji
    • NewsAPI. Zdobądź najnowsze nagłówki biznesowe ze Stanów Zjednoczonych

  2. W przypadku interfejsów API, które wymagają klucza interfejsu API, użyj podanego linku, aby ubiegać się o klucz interfejsu API i wprowadź go w polu wejściowym. Następnie łącznik automatycznie tworzy połączenie w chmurze Fabric i wstępnie wypełnia wymagane nagłówki i parametry HTTP.

    Ważne

    Przykładowy interfejs API binance nie wymaga klucza interfejsu API, ale odpowiadasz za przestrzeganie warunków użytkowania.

  3. Jeśli wybierzesz pozycję Użyj istniejącego połączenia, wybierz pozycję Zastosuj przykład , aby wstępnie wypełnić wymagane nagłówki i parametry dla przykładowego interfejsu API bez wprowadzania klucza interfejsu API.

  4. Alternatywnie wybierz pozycję Zakończ , aby zamknąć okno i skonfigurować własne źródło HTTP od podstaw.

Konfigurowanie własnego źródła HTTP

Wykonaj kroki, aby skonfigurować własne źródło HTTP bez przykładowego interfejsu API.

  1. Utwórz nowe połączenie. Wybierz pozycję Nowe połączenie i wprowadź wymagane właściwości źródła HTTP:

    Zrzut ekranu pokazujący, gdzie wybrać nową stronę połączenia.

    • Podstawowy adres URL: podstawowy adres URL punktu końcowego HTTP.
    • Identyfikator URI odbiorców tokenu (opcjonalnie): zasób, dla którego jest przeznaczony token.
    • Nazwa połączenia: wprowadź nazwę połączenia.
    • Rodzaj uwierzytelniania: Obecnie Łącznik HTTP obsługuje tylko uwierzytelnianie Anonymous, Basic i API Key.

    Zrzut ekranu przedstawiający nową stronę połączenia.

  2. Metoda żądania: Wybierz GET lub POST.

  3. Nagłówki i parametry: w przypadku wybrania uwierzytelniania klucza interfejsu API podczas tworzenia połączenia w chmurze użyj parametru dynamicznego ${apiKey} w nagłówkach lub parametrach, aby odwołać się do klucza interfejsu API.

    Aby na przykład nawiązać połączenie z witryną CoinGecko, użyj nagłówka: x_cg_demo_api_key = ${apiKey}.

    Ważne

    Nie należy podawać klucza API ani innych poświadczeń w nagłówkach lub parametrach.

  4. Interwał żądania (s): określa czas oczekiwania w sekundach między kolejnymi żądaniami; prawidłowy zakres to [1, 3600].

  5. Maksymalna liczba ponownych prób: maksymalna liczba ponownych prób w łączniku w przypadku wystąpienia błędu; prawidłowy zakres to [10, 100].

  6. Odstęp przed ponowną próbą (s): czas w sekundach oczekiwania po błędzie przed ponownym podjęciem próby łącza; prawidłowy zakres to [1, 3600].

  7. Kod stanu ponawiania: zwrócone kody błędów HTTP, które skłaniają łącznik do ponowienia próby żądania. Wprowadź rozdzielaną przecinkami listę kodów lub zakres kodów. Zakresy są określane przy użyciu kodu początkowego i opcjonalnego kodu końcowego. Przykład:

    • 400- zawiera wszystkie kody większe lub równe 400.
    • 400-500 zawiera kody z zakresu od 400 do 500, w tym 500.
    • 404,408,500- powoduje, że łącznik ponawia próbę dla 404 NIE ZNALEZIONO, 408 ŻĄDANIE PRZEKROCZYŁO LIMIT CZASU oraz wszystkich kodów błędów 5xx.

    Niektóre kody stanu są zawsze ponawiane, takie jak nieautoryzowane, przekroczenia limitu czasu i zbyt wiele żądań.

    Zrzut ekranu przedstawiający skonfigurowane ustawienia.

  8. Przejrzyj podsumowanie konfiguracji źródła HTTP i wybierz pozycję Dodaj.

    Zrzut ekranu przedstawiający stronę konfiguracji przeglądu.

Źródło HTTP dodane do strumienia zdarzeń jest widoczne w trybie edycji.

Zrzut ekranu przedstawiający dodane źródło HTTP w trybie edycji z wyróżnionym przyciskiem Publikuj.

Wybierz Publikuj, aby wprowadzić zmiany i rozpocząć przesyłanie danych strumieniowych ze źródła HTTP do strumienia zdarzeń.

Zrzut ekranu przedstawiający dodane źródło HTTP w widoku na żywo z wyróżnionym przyciskiem Publikuj.

Limitation

  • Łącznik HTTP obsługuje obecnie tylko odpowiedzi interfejsu API JSON .
  • Uwierzytelnianie OAuth nie jest obsługiwane.
  • Źródło HTTP nie obsługuje funkcji ciągłej integracji/ciągłego wdrażania, w tym integracji z usługą Git i potoku wdrażania. Eksportowanie lub importowanie elementu strumienia zdarzeń, który zawiera to źródło za pośrednictwem usługi Git, może spowodować błędy.

Treści powiązane

Inne łączniki:

  • Last updated on