Condividi tramite


Aggiungere un'origine HTTP a un flusso di eventi (anteprima)

Questo articolo illustra come aggiungere un'origine HTTP a un flusso di eventi.

Il connettore HTTP offre un modo senza codice configurabile per trasmettere i dati da qualsiasi API REST direttamente in Eventstream per l'elaborazione in tempo reale. Consente di eseguire continuamente il pull dei dati dalle piattaforme SaaS e dai feed di dati pubblici e di analizzare automaticamente le risposte JSON in eventi strutturati. Offre anche feed pubblici di esempio che consentono di iniziare rapidamente, semplicemente selezionare un'API di esempio, immettere la chiave API e consentire a Eventstream di precompilare le intestazioni e i parametri necessari.

Prerequisiti

  • Un'area di lavoro con capacità Fabric o modalità di licenza Trial.
  • Accesso all'area di lavoro con ruoli collaboratore o superiore dell'area di lavoro.
  • Se non si dispone di un flusso di eventi, seguire la guida per creare un flusso di eventi.

Aggiungere HTTP come origine

Se non è ancora stata aggiunta alcuna origine al flusso di eventi, selezionare il riquadro Usa origine esterna .

Screenshot che mostra la selezione del tile per usare un'origine esterna.

Se si aggiunge l'origine a un flusso di eventi già pubblicato, passare alla modalità Modifica. Sulla barra multifunzione selezionare Aggiungi origine>Origini esterne.

Screenshot che mostra le selezioni per l'aggiunta di fonti esterne.

Cercare http e selezionare Connetti per aggiungere il connettore HTTP al flusso di eventi.

Screenshot che mostra la selezione di HTTP come tipo di origine nella procedura guidata Selezionare un'origine dati.

Configurare e connettersi a HTTP

È possibile selezionare una delle API pubbliche di esempio per iniziare rapidamente con intestazioni e parametri predefiniti oppure selezionare Esci per configurare il proprio connettore HTTP personalizzato.

Usare api pubbliche di esempio

  1. Selezionare un'API pubblica di esempio per configurare rapidamente il connettore HTTP: screenshot che mostra la pagina dell'API di esempio.

    • Binance. Ottenere il prezzo di Bitcoin più recente
    • CoinGecko. Ottenere il prezzo corrente bitcoin in USD
    • Trasporto per Londra. Ottenere stime di arrivo in tempo reale per una stazione di Londra
    • Alfa Vantage. Ottenere il prezzo azionario MSFT in tempo reale
    • OpenWeather. Ottenere le previsioni meteo per una località
    • NewsAPI. Ottieni le notizie di business più recenti dagli Stati Uniti
  2. Per le API che richiedono una chiave API, usare il collegamento fornito per applicare la chiave API e immetterlo nella casella di input. Il connettore crea quindi automaticamente la connessione cloud fabric e precompila le intestazioni e i parametri HTTP necessari.

    Importante

    L'API di esempio binance non richiede una chiave API, ma è responsabile della conformità alle condizioni per l'utilizzo.

  3. Se si sceglie Usa connessione esistente, selezionare Applica esempio per precompilare le intestazioni e i parametri necessari per l'API di esempio senza immettere una chiave API.

  4. In alternativa, selezionare Esci per chiudere la finestra e configurare la propria origine HTTP da zero.

Configurare un'origine HTTP personalizzata

Seguire la procedura per configurare un'origine HTTP personalizzata senza un'API di esempio.

  1. Creare una nuova connessione. Selezionare Nuova connessione e immettere le proprietà necessarie per l'origine HTTP:

    Screenshot che mostra dove selezionare la nuova pagina di connessione.

    • URL di Base: L'URL di base dell'endpoint HTTP.
    • Token Audience Uri (facoltativo): risorsa per cui il token è destinato.
    • Nome connessione: immettere un nome per la nuova connessione.
    • Tipo di autenticazione: attualmente il connettore HTTP supporta Anonymoussolo , Basice API Key l'autenticazione.

    Screenshot che mostra la nuova pagina di connessione.

  2. Metodo di richiesta: selezionare GET o POST.

  3. Intestazioni e parametri: se è stata selezionata l'autenticazione della chiave API quando è stata creata la connessione cloud, usare il parametro dinamico ${apiKey} nelle intestazioni o nei parametri per fare riferimento alla chiave API.

    Ad esempio, per connettersi a CoinGecko, usare l'intestazione : x_cg_demo_api_key = ${apiKey}.

    Importante

    NON immettere la chiave API o altre credenziali nelle intestazioni o nei parametri.

  4. Intervallo di richiesta (s): specifica il tempo in secondi di attesa tra le richieste consecutive; l'intervallo valido è [1, 3600].

  5. Numero massimo di tentativi: numero massimo di tentativi che il connettore ritenta una richiesta quando si verifica un errore; l'intervallo valido è [10, 100].

  6. Intervallo di ripetizione (s): il tempo in secondi di attesa dopo un errore prima che il connettore riprovi; l'intervallo valido è compreso tra [1, 3600].

  7. Codice di stato di ripetizione dei tentativi: i codici di errore HTTP restituiti che richiedono al connettore di ripetere la richiesta. Immettere un elenco delimitato da virgole di codici o intervallo di codici. Gli intervalli vengono specificati con un codice finale iniziale e facoltativo. Per esempio:

    • 400- include tutti i codici maggiori o uguali a 400.
    • 400-500 include codici compresi tra 400 e 500, inclusi 500.
    • 404,408,500- richiede al connettore di riprovare su 404 NOT FOUND, 408 REQUEST TIMEOUT e tutti i codici di errore 5xx.

    Alcuni codici di stato vengono sempre ripetuti, come errore di autorizzazione, timeout e troppe richieste.

    Screenshot che mostra le impostazioni configurate.

  8. Esaminare il riepilogo della configurazione per l'origine HTTP e selezionare Aggiungi.

    Screenshot che mostra la pagina di configurazione di revisione.

È possibile visualizzare l'origine HTTP aggiunta al flusso di eventi in modalità di modifica.

Screenshot dell'origine HTTP aggiunta in modalità di modifica con il pulsante Pubblica evidenziato.

Selezionare Pubblica per pubblicare le modifiche e avviare lo streaming dei dati dall'origine HTTP al flusso di eventi.

Una schermata della fonte HTTP aggiunta nella live view con il pulsante Pubblica in evidenza.

Limitation

  • Il connettore HTTP supporta attualmente solo le risposte dell'API JSON .
  • L'autenticazione OAuth non è supportata.
  • L'origine HTTP non supporta le funzionalità CI/CD, inclusa l'integrazione git e la pipeline di distribuzione. L'esportazione o l'importazione di un elemento Eventstream che include questa origine tramite Git possono causare errori.

Altri connettori: