Opas: Luo end-to-end Activator-sääntö agenttitekoälyllä

Fabric Activator tunnistaa kuvioita suoratoistodatassa ja ryhtyy toimiin, kun ehdot täyttyvät. Tässä opetusohjelmassa käytät tekoälyagenttia rakentaaksesi kokonaisvaltaisen putkiston. Putki seuraa telemetriatapahtumien virtaa, havaitsee jatkuvan ylikuumenemisen ja kutsuu Fabric User Data Functionin (UDF) korjaustyön tekemiseen. Kirjoitat aiheet; Agentti tekee kirjoittamisen.

Tässä opas käyttää widget-making-machine -telemetriaa juoksevana esimerkkinä, mutta samat kehotteet toimivat lähes mille tahansa aikasarjadatalle, jossa on vakaa yksilökohtainen ID—IoT-laitteet, ajoneuvokalustot, logistiikkatapahtumat, taloudelliset tickit, sovellusmittarit ja niin edelleen. Vaihda kenttien nimet ja kynnysarvo sopimaan datan muotoosi.

Tässä opetusohjelmassa suoritat seuraavat tehtävät:

  • Perusta eventstream tapahtumakeskuksesi kautta.
  • Luo käyttäjätietofunktio korjaustyön tallentamista varten.
  • Laadi aktivaattorisääntö, joka laukaisee funktion.

Jos olet uusi Fabric Activatorin käyttäjä, katso Mikä on Fabric Activator?. Jos olet uusi Fabric käyttäjätietofunktioiden käyttäjä, katso Mitkä ovat Fabric User Data Functions?.

Skenaarion yleiskatsaus

Valmistaja operoi widget-valmistuskoneiden kalustoa useissa tehtaissa. Jokainen kone lähettää telemetriaa—lämpötilaa, värähtelyä, painetta, käyttötilaa—Azure-tapahtumakeskukseen. Kun kone ylläpitää korkeaa käyttölämpötilaa, se tarvitsee huoltokäynnin ennen kuin se hajoaa.

Tässä opetusohjelmassa jokainen tapahtuma käyttää pientä edustavaa skeemaa: konekohtaista tunnistetta (machine_id), sijaintitagia (plant_id), numeerista metriikkaa seurattavaksi (temperature_c), ja juoksutilakenttää (state). Kenttien tarkat nimet eivät merkitse mitään—sama kehotemuoto toimii mille tahansa entiteetin ID:lle sekä mittarille, jonka haluat asettaa.

Rakennat Fabric-putken, joka seuraa telemetriavirtaa, soveltaa jatkuvan kynnysarvon sääntöä ja kutsuu User Data -funktion korjaustyön tallentamiseksi. Sääntö ryhmittelee tapahtumat ja machine_id laukea, kun temperature_c lämpötila pysyy yli 50°C 5 minuutin ajan. Kun se laukeaa, se kulkee machine_id, plant_id, ja nykyisen lämpötilan mukaan toimintaan.

arkkitehtuurin kaavio telemetriasta, joka virtaa koneista Azure Event Hubs:n kautta, Fabric tapahtumavirta, aktivaattorisääntö ja UDF.

Ennakkovaatimukset

Ennen kuin aloitat, tarvitset seuraavat asiat:

  • Fabric-työtila F4 (tai sitä suuremmalla) kapasiteetilla, jossa on tekijäoikeudet. Jos haluat tietää työtiloista, katso Workspaces.
  • Taitoyhteensopiva agentti—esimerkiksi GitHub Copilot CLI tai GitHub Copilot Visual Studio Code:ssa—johon on asennettu Fabric skills.
  • Azure Event Hubs -nimiavaruus ja keskus, joka striimaa telemetriaa. Tarvitset nimiavaruuden FQDN:n, hubin nimen ja Listen+Send yhteysmerkkijono.

Aseta tapahtumavirta

Tässä vaiheessa luot tapahtumavirran, joka tilaa tapahtumakeskuksesi. Kysyt agentilta ja varmistat tuloksen portaalissa.

  1. Anna agentille tämä kehote, korvaa paikkamerkit tapahtumakeskuksen arvoilla:

    Create a Fabric eventstream in my workspace called `WidgetMachineTelemetry` that ingests from this Azure event hub:

- Namespace: `<your namespace FQDN>`
- Hub name: `<your hub name>`
- Connection string: `<your Listen+Send connection string>`

When you're done, give me a direct portal link to the eventstream item so I can verify it.

  2. Agentti käyttää eventstreamin kirjoittamistaidon taitoa. Se luo tapahtumavirran kohteen, konfiguroi tapahtumakeskuksen lähteeksi ja palauttaa klikattavan URL-osoitteen kohteeseen Fabric-portaalissa. Et tarvitse kohdetta—Activator tilaa suoraan streamin.

  3. Valitse agentin antama linkki. Live-näkymässä varmista, että tapahtumakeskuksen lähde on yhdistetty ja widget-koneen telemetriatapahtumat kulkevat läpi.

    WidgetMachineTelemetryn tapahtumavirran kuvakaappaus, jossa tapahtumakeskuksen lähde on yhdistetty ja Aktivaattorin kohde, reaaliaikaisella datan esikatselulla.

    Kuva 1: Tapahtumavirta WidgetMachineTelemetry —tapahtumat virtaavat widget-telemetry tapahtumakeskuksen lähteestä virran WidgetMachineMaintenance kautta Aktivaattorin kohteeseen.

Luo käyttäjätietofunktio

Tässä vaiheessa luot käyttäjätietofunktion, jota Aktivaattorin sääntö kutsuu. Funktio lähettää korjaustyöpyynnön alavirran API:lle.

  1. Anna agentille tämä tehtävä:

    Create a Fabric User Data Function called `MaintenanceDispatcher` in my workspace, written in Python, with a function `file_repair_job(machine_id, plant_id, temperature_c)` that sends those values as JSON in a POST request to `https://contoso.com/maintenance/fileRepairJob` and returns the parsed response.

When you're done, give me a direct portal link to the UDF item so I can verify it.

  2. Agentti käyttää Fabric UDF -authoring -taitoa. Se rakentaa Python UDF-kohteen, toteuttaa file_repair_jobhttpx:lla, julkaisee UDF:n, vahvistaa funktion kutsuttavaksi ja palauttaa klikattavan URL-osoitteen kohteeseen.

  3. Valitse agentin antama linkki ja käytä sisäänrakennettua testipaneelia käynnistääksesi file_repair_job näytteen. Esimerkiksi: machine_id="widget-press-042", plant_id="plant-eu-01", temperature_c=52.7. Kutsu palauttaa contoso.com HTTP-virheen – se on odotettavissa, koska paikkamerkki ei ratkea. Tärkeintä on, että UDF otti käyttöön, rekisteröityi ja tavoitti lähtevän HTTP-kutsun.

    Kuvakaappaus MaintenanceDispatcherin käyttäjätietotoiminnosta, joka näyttää file_repair_job Python lähteen portaalin editorissa.

    Kuva 2: User MaintenanceDispatcher Data Function —file_repair_job lähettää ylikuumenevan koneen tiedot huoltojärjestelmälle.

Muistio

Tämä opas toimii https://contoso.com/maintenance/fileRepairJob paikkamerkkinä todelliselle huoltojärjestelmän päätepisteelle. Korvaa se millä tahansa omalla HTTPS-päätepisteelläsi. Todennetut päätepisteet varten hae tunnistetiedot Azure Key Vault -sovelluksesta UDF-yleisen yhteyden kautta. Lisätietoja löytyy osoitteesta Access tietolähteet Fabric User data functions.

Kirjoittaja Aktivaattorisäännön

Tässä vaiheessa luot Aktivaattorisäännön, joka seuraa tapahtumavirtaa ja kutsuu UDF:n, kun kone ylikuumenee.

  1. Anna agentille tämä tehtävä:

    Create an Activator rule in my workspace subscribed to the `WidgetMachineTelemetry` eventstream, that triggers my `file_repair_job` UDF when a machine's temperature stays above 50°C for 5 minutes.

When you're done, give me a direct portal link to the rule so I can verify it.

  2. Agentti kutsuu aktivoijan kirjoittamistaidon ja luo aktivaattoriesineen. Agentti ryhmittelee säännön seuraavasti machine_id, rakentaa jatkuvan kynnysarvon havaitsemisen ja konfiguroi toiminnon kutsumaan UDF:si , machine_idplant_id, ja nykyisen lämpötilan kanssa. Agentti palauttaa sitten klikattavan URL-osoitteen sääntöön.

  3. Valitse agentin antama linkki ja käy läpi tämä tarkistuslista:

    • Data virtaa sääntöön. Avaa säännön taustalla oleva Activator-objekti Explorer-paneelissa ja varmista, että viimeaikaiset tapahtumat näkyvät live-taulukossa ei-null machine_id - ja temperature_c arvoilla.
    • Sääntö on juokseminen. Varmista, että sääntö on Käynnistetty - tai Käynnissä-tilassa ja Aktivaattorin objektin yhteenveto näyttää koneesi aktiivisina instansseina.
    • Agentti tallentaa aktivoinnit. Kun ylikuumentavat koneet pysyvät yli 50°C 5 minuutin ajan, säännön Historia-välilehdelle ilmestyy merkintöjä, joissa näkyy machine_id laukaistu lämpötila, tulipalon lämpötila ja onnistunut kutsu file_repair_job.

    Kuvakaappaus OverheatingDispatch Activator -säännöstä, jossa toiminto kutsuu file_repair_job UDF:ää ja välittää koneen ID:n, laitoksen ID:n ja lämpötilan parametreina.

    Kuva 3: Aktivaattorisääntö OverheatingDispatch —aktivoituu, kun koneen lämpötila pysyy yli 50°C viiden minuutin ajan, file_repair_job ja koneen identiteetti, voimakkuus ja nykyinen lämpötila aktivoituu.

Puhdista resurssit

Kun olet valmis, poista Eventstream, User Data Function ja Activator -elementit työtilastasi, ja poista Event Hubsin nimiavaruus Azure-portaalista estääksesi maksut.

Liittyvä sisältö

  • Last updated on