Lisää HTTP-lähdekoodi tapahtumavirtaan (esikatselu)

Tässä artikkelissa näytetään, miten HTTP-lähde lisätään tapahtumavirtaan.

HTTP-liitin tarjoaa koodittoman ja konfiguroitavan tavan suoratoistaa dataa mistä tahansa REST-rajapinnasta suoraan Eventstreamiin reaaliaikaista käsittelyä varten. Sen avulla voit jatkuvasti hakea dataa SaaS-alustoilta ja julkisista tietovirroista sekä automaattisesti jäsentää JSON-vastaukset rakenteellisiin tapahtumiin. Se tarjoaa myös esimerkkijulkisia syötteitä, joiden avulla pääset nopeasti alkuun, valitset esimerkki-API:n, syötät API-avaimen ja antavat Eventstreamin täyttää tarvittavat otsikot ja parametrit.

Ennakkovaatimukset

  • Työtila, jonka kapasiteetti on Fabric tai Fabric Trial työtilatyyppi.
  • Pääsy työtilaan Contributor - tai korkeammilla työtilarooleilla.
  • HTTP-päätepiste, joka on julkisesti saatavilla. Jos se sijaitsee suojatussa verkossa, yhdistä siihen käyttämällä Eventstream-liittimen virtuaaliverkkoinjektiota.

Lisää HTTP lähteeksi

Jos et ole vielä lisännyt lähdettä tapahtumavirtaasi, valitse Yhdistä tietolähteet -ruutu. Voit myös valita Lisää lähde>Yhdistä tietolähteet nauhalla.

Kuvakaappaus, joka näyttää laatan valinnan ulkoisen lähteen käyttöön.

Jos lisäät lähdekoodin jo julkaistuun tapahtumavirtaan, vaihda muokkaustilaan . Nauhalta valitse Lisää lähde>Yhdistä tietolähteet.

Kuvakaappaus, joka näyttää vaihtoehtoja ulkoisten lähteiden lisäämiseen.

Etsi http ja valitse Connect lisätäksesi HTTP-liittimen tapahtumavirtaan.

Kuvakaappaus, joka näyttää HTTP:n valinnan lähdetyypiksi Select a Data Source -velhossa.

Määritä ja yhdistä HTTP:hen

Voit valita jonkin Esimerkkijulkisista API-rajapinnoista aloittaaksesi nopeasti ennalta määritellyillä otsikoilla ja parametreilla, tai valita Exit konfiguroidaksesi oman mukautetun HTTP-liittimesi.

Käytä esimerkkejä julkisista rajapinnoista

  1. Valitse esimerkki julkinen API, jotta HTTP-liitin voidaan nopeasti määrittää: Kuvakaappaus, joka näyttää esimerkki-API-sivun.

    • Binance. Saat uusimmat Bitcoin-hinnat
    • CoinGecko. Hanki nykyinen Bitcoin-hinta USD:ssä
    • Kuljetus Lontooseen. Saat reaaliaikaiset saapumisennusteet Lontoon asemalle
    • Alpha Vantage. Saat reaaliaikaisen Microsoft (MSFT) -osakekurssin
    • OpenWeather. Hanki sääennuste sijainnista
    • NewsAPI. Saat viimeisimmät liiketoiminnan uutiset Yhdysvalloissa

  2. API-rajapinnoissa, jotka vaativat API-avaimen, käytä annettua linkkiä hakeaksesi API-avainta ja syötä se syöttölaatikkoon. Liitin luo automaattisesti Fabric-pilviyhteyden ja täyttää tarvittavat HTTP-otsikot ja parametrit.

    Tärkeää

    Binancen esimerkki-API ei vaadi API-avainta, mutta olet vastuussa sen käyttöehtojen noudattamisesta.

  3. Jos valitset Käytä olemassa olevaa yhteyttä, valitse Apply example täyttääksesi vaaditut otsikot ja parametrit esimerkki-API:lle ilman API-avaimen lisäämistä.

  4. Vaihtoehtoisesti valitse Exit sulkeaksesi ikkunan ja konfiguroidaksesi oman HTTP-lähteesi alusta alkaen.

Määritä oma HTTP-lähdekoodisi

Seuraa ohjeita konfiguroidaksesi oman HTTP-lähteesi ilman esimerkki-API:ta.

  1. Luo uusi yhteys. Valitse Uusi yhteys ja syötä tarvittavat ominaisuudet HTTP-lähteellesi:

    Kuvakaappaus, joka näyttää, mistä valitaan uusi yhteyssivu.

    • Perus-URL: HTTP-päätepisteen perus-URL.
    • Token Audience Uri (valinnainen): Resurssi, johon token on tarkoitettu.
    • Yhteyden nimi: Syötä yhteyden nimi.
    • Todennustyyppi: Tällä hetkellä HTTP-liitin tukee Anonymousvain , Basic, ja API Key tunnistautumista.

    Kuvakaappaus, joka näyttää uuden yhteyssivun.

  2. Pyyntömenetelmä: Valitse GET tai POST.

  3. Otsikot ja parametrit: Jos valitsit API-avaimen tunnistautumisen pilviyhteyden luodessasi, käytä dynaamista parametria ${apiKey} otsikoissasi tai parametreissasi API-avaimen viittaamiseen.

    Esimerkiksi yhdistääksesi CoinGeckoon, käytä otsikkoa: x_cg_demo_api_key = ${apiKey}.

    Tärkeää

    ÄLÄ syötä API-avaintasi tai muita tunnistetietojasi otsikoihin tai parametreihin.

  4. Pyyntöväli (s): Määrittää odotusajan sekunneissa peräkkäisten pyyntöjen välillä; Voimassa oleva alue on [1,3600].

  5. Maksimikokeilut: Suurin määrä kertoja, jolloin liitin yrittää pyynnön uudelleen virheen tapahtuessa; Pätevä alue on [10, 100].

  6. Retry backoff (s): Aika sekunteina odotus virheen jälkeen ennen liittimen uudelleenkäynnistystä; Voimassa oleva alue on [1,3600].

  7. Uudelleenyrityksen tilakoodi: HTTP-virhekoodit palautuivat, jotka kehottavat liitintä yrittämään pyynnön uudelleen. Syötä pilkulla erotettu koodilista tai koodialue. Etäisyydet määritellään aloitus- ja valinnaisella loppukoodilla. Esimerkki:

    • 400- sisältää kaikki koodit, jotka ovat suurempia tai yhtä suuret kuin 400.
    • 400-500 sisältää koodeja 400–500, mukaan lukien 500.
    • 404,408,500- pyytää liitintä yrittämään uudelleen 404 NOT FOUND, 408 REQUEST TIMEOUT ja kaikki 5xx virhekoodit.

    Jotkin tilakoodit kokeillaan aina uudelleen, kuten luvattomuus, aikakatkaisut ja liian monet pyynnöt.

    Kuvakaappaus, joka näyttää asetukset.

Käsittele sivutettuja rajapintoja

Jotkut REST-rajapinnat palauttavat dataa useilla sivuilla yhden vastauksen sijaan. Esimerkiksi API voi palauttaa 100 tietuetta jokaisessa vastauksessa ja vaatia lisäpyyntöjä jäljellä olevien tietueiden hakemiseksi. HTTP-liitin tukee sivuttamista, jotta se voi hakea dataa useilta sivuilta kyselysyklin aikana.

Tuetut sivutyypit

HTTP-liitin tukee näitä sivutusmalleja:

  • Sivupohjainen sivutus: Pyyntö sisältää sivuparametrin, kuten page=1 tai page=2. Liitin kasvattaa sivunumeroa pyytääkseen seuraavaa sivua.
  • Kursoripohjainen sivutus: API-vastaus sisältää kursori- tai jatkotokenin, kuten continuationToken tai nextPageToken. Liitin käyttää tätä arvoa pyytääkseen seuraavaa sivua.

Sivutuksen konfigurointi

Sivuttamisen käyttöä varten määritä HTTP-liittimessä seuraavat asetukset:

  • Sivutus päällä: Kytkee sivunkäsittelyn päälle.
  • Sivutustila: Määrittää sivutyypin. Tuetut arvot ovat Page ja Cursor.
  • Vastausdata JSON-osoitin: Määrittää datataulukon sijainnin API-vastauksessa, kuten /value, /items, tai /articles.

Sivupohjainen sivutusesimerkki

Sivupohjaisessa API:ssa ensimmäinen pyyntö voi olla GET /api/data?page=1.

Esimerkki kokoonpanosta:

  • Sivutus sallittu: true.
  • Sivutustila: Sivu.

Liitin lähettää pyyntöjä seuraaville sivuille, kuten page=2 ja page=3. Sivutus loppuu, kun API-vastaus osoittaa, ettei lisätietoja ole saatavilla, esimerkiksi palauttamalla tyhjä taulukko.

Kursoripohjainen sivutusesimerkki

Kursoripohjaisessa API:ssa vastaus voi sisältää jatkotunnuksen, kuten "continuationToken": "ABC123".

Liitin poimii jatkotunnuksen ja käyttää sitä seuraavassa pyynnössä, kuten GET /api/data?continuationToken=ABC123. Sivutus loppuu, kun vastaus ei sisällä toista tokenia tai tokenin arvo on nolla.

Kun sivutus loppuu

Liitin lopettaa lisäsivujen pyytämisen, kun jokin seuraavista ehdoista täyttyy:

  • API palauttaa tyhjän vastauksen.
  • Vastauksessa ei ole seuraavan sivun tokenia.
  • API kertoo, ettei enää ole saatavilla sivuja.

Huomioitavia seikkoja

  • Jokainen äänestyskierros alkaa ensimmäiseltä sivulta.
  • Varmista, että API tukee sivuttamista ennen kuin otat tämän ominaisuuden käyttöön.
  • Virheellinen sivuasetus tai JSON-osoittimen asetukset voivat aiheuttaa puuttuvia tai päällekkäisiä tietoja.

Käytä sivuttamista, kun API rajoittaa palautettujen tietueiden määrää kussakin pyynnössä.

Striimin tai lähteen tiedot

  1. Connect-sivulla seuraa jotakin näistä vaiheista sen mukaan, käytätkö Eventstreamia vai Real-Time hubia.

    • Eventstream:

      Lähdetiedot-paneelissa oikealla seuraa seuraavia ohjeita:

      1. Lähdenimeä varten valitse Kynäpainike vaihtaaksesi nimen.

      2. Huomaa, että Eventstreamin nimi ja Streamin nimi ovat vain luku -tilassa.

    • Real-Time keskus:

      Oikealla olevassa Stream-tiedot-osiossa seuraa näitä vaiheita:

      1. Valitse Fabric workspace johon haluat luoda eventstreamin.

      2. Eventstreamin nimeä varten valitse Kynäpainike ja syötä tapahtumavirran nimi.

      3. Virran nimiarvo luodaan automaattisesti lisäämällä -stream tapahtumavirran nimeen. Tämä virta ilmestyy reaaliaikaisen hubin Kaikki datavirrat -sivulle, kun ohjattu on valmis.

  2. Valitse Seuraava Määritä-sivun alareunasta.

Kertaile ja yhdistä

Review + connect -näytöllä käy läpi yhteenveto ja valitse Add (Eventstream) tai Connect (Real-Time hub).

Voit nähdä HTTP-lähteen lisättynä tapahtumavirtaasi muokkaustilassa.

Kuvakaappaus lisätystä HTTP-lähteestä Muokkaustilassa, jossa Julkaise-painike on korostettu.

Valitse Julkaise julkaistaaksesi muutokset ja aloittaaksesi datan suoratoiston HTTP-lähteestä tapahtumavirtaan.

Kuvakaappaus lisätystä HTTP-lähteestä Live View -näkymässä, jossa on Julkaise-painike korostettuna.

Rajoitukset

  • HTTP-liitin tukee tällä hetkellä vain JSON API -vastauksia.
  • OAuth-tunnistautumista ei tueta.
  • HTTP-lähdekoodi ei tue CI/CD-ominaisuuksia, mukaan lukien Git Integration ja Deployment Pipeline. Eventstream-kohteen, joka sisältää tämän lähteen, vienti tai tuonti Gitin kautta voi aiheuttaa virheitä.

Liittyvä sisältö

Muut liittimet:

  • Last updated on