Megosztás a következőn keresztül:

Írás Azure SQL Database-táblába az Azure Stream Analytics-feladatokból

  • Cikk

Az Azure Stream Analytics támogatja a Azure SQL Database-t a streamelési lekérdezés kimeneteként. Ez a cikk azt ismerteti, hogyan használhatja SQL Database kimenetként a Stream Analytics-feladathoz a Azure Portal.

Előfeltételek

  1. Stream Analytics-feladat létrehozása.

  2. Hozzon létre egy Azure SQL-adatbázist, amelybe a Stream Analytics-feladat kimenetet fog írni.

Írás új táblába a SQL Database

Ez a szakasz bemutatja, hogyan konfigurálhatja a feladatot úgy, hogy a még nem létrehozott Azure SQL-adatbázisban lévő táblába írjon.

  1. A Stream Analytics-feladatban válassza a Kimenetek lehetőséget a Feladattopológia területen. Kattintson a Hozzáadás gombra, és válassza a SQL Database lehetőséget.

    Képernyőkép az SQL DB kimenetről a Stream Analyticsben.

  2. Válasszon ki egy kimeneti aliast, amelyet használni fog a feladat lekérdezésében. Adja meg az adatbázis nevét és hitelesítési módját. További információ az SQL kimeneti konfigurációs beállításairól.

  3. Adjon meg egy táblanevet, amelyet létre szeretne hozni a Azure SQL-adatbázisban. Kattintson a Mentés gombra. Megjegyzés: A kimenet mentése nem hozza létre a táblát a SQL Database. A következő lépések további részleteket nyújtanak a tábla létrehozásának időpontjáról.

    Képernyőkép az SQL DB kimeneti konfigurációjáról a Stream Analyticsben.

  4. Válassza a Lekérdezés lehetőséget a Feladattopológia területen, és használja a lekérdezés aliasát a kimenet írásához az előző lépésben megadott táblanévben. Kattintson a Lekérdezés tesztelése elemre a lekérdezési logika teszteléséhez, és tekintse meg a feladat által előállított kimenet sémáját megjelenítő teszteredményeket . Megjegyzés: A lekérdezés teszteléséhez bejövő streamelési adatokat kell megadnia a bemeneti forrásban, vagy feltölthet mintaadatokat a lekérdezés teszteléséhez. További információ a Stream Analytics-lekérdezés teszteléséről.

    Képernyőkép a Lekérdezéstesztelésről a Stream Analyticsben.

    Képernyőkép a lekérdezési tesztek eredményeiről a Stream Analyticsben.

  5. Kattintson az SQL-táblaséma elemre az oszlop nevének és típusának megtekintéséhez. Kattintson a Tábla létrehozása gombra, és a tábla létrejön az SQL-adatbázisban.

    Képernyőkép egy tábla SQL-adatbázisban való létrehozásáról a Stream Analyticsből.

    Ha a Stream Analytics-lekérdezést úgy módosítják, hogy más sémát hoz létre, módosítania kell a tábladefiníciót a SQL Database. Ez biztosítja, hogy a Stream Analytics-feladat ne tapasztaljon adatkonvertálási hibákat a fogadóba való írás közben.

  6. A lekérdezés véglegesítése után válassza az Áttekintés lehetőséget, és indítsa el a feladatot. Ezután navigálhat a SQL Database táblához a streamelési lekérdezés kimenetének megtekintéséhez.

Válasszon ki egy meglévő táblát a SQL Database

Ez a szakasz azt ismerteti, hogyan konfigurálhatja a feladatot úgy, hogy olyan táblába írjon, amely már létezik a Azure SQL-adatbázisban.

  1. A Stream Analytics-feladatban válassza a Kimenetek lehetőséget a Feladattopológia területen. Kattintson a Hozzáadás gombra, és válassza a SQL Database lehetőséget.

    Képernyőkép az SQL DB kimenetről a Stream Analyticsben.

  2. Válasszon ki egy kimeneti aliast, amelyet használni fog a feladat lekérdezésében. Adja meg az adatbázis nevét és hitelesítési módját. További információ az SQL kimeneti konfigurációs beállításairól.

  3. A kijelölt SQL Database kiválaszthat egy meglévő táblát az SQL-hitelesítés részleteinek megadásával. Ezzel betölti a táblanevek listáját az adatbázisból. Válassza ki a táblázat nevét a listából, vagy manuálisan adja meg a tábla nevét és a Mentés parancsot.

    Képernyőkép az SQL Database-ben meglévő tábláról.

  4. Válassza a Lekérdezés lehetőséget a Feladattopológia területen, és a lekérdezés aliasnevével írja be a kimenetet a kijelölt táblába. Kattintson a Lekérdezés tesztelése elemre a lekérdezési logika teszteléséhez és a teszteredmények megtekintéséhez. Megjegyzés: A lekérdezés teszteléséhez bejövő streamelési adatokkal kell rendelkeznie az Event Hubban/IoT Hub, vagy feltölthet mintaadatokat a lekérdezés teszteléséhez. További információ a Stream Analytics-lekérdezés teszteléséről.

    Képernyőkép a Lekérdezéstesztelésről a Stream Analyticsben.

    Képernyőkép a lekérdezési tesztek eredményeiről a Stream Analyticsben.

  5. Az SQL-tábla séma lapján láthatja az oszlop nevét és típusát a bejövő adatokból és a kijelölt táblából. Láthatja az állapotot, hogy a bejövő adattípus és a kijelölt SQL-tábla egyezik-e. Ha nem egyezik, a rendszer kérni fogja, hogy frissítse a lekérdezést a táblaséma egyeztetésére.

    A Stream Analytics séma-összehasonlítását bemutató képernyőkép.

  6. A lekérdezés véglegesítése után válassza az Áttekintés lehetőséget, és indítsa el a feladatot. Ezután navigálhat a SQL Database táblához a streamelési lekérdezés kimenetének megtekintéséhez.

Az adattípusok eltérésének gyakori okai

Fontos meggyőződni arról, hogy a Stream Analytics-feladat kimenete megegyezik a SQL Database tábla által várt oszlopnevekkel és adattípusokkal. Ha eltérés van, a feladat adatkonvertálási hibákba ütközik, és folyamatosan próbálkozik, amíg az SQL-tábla definíciója nem változik. Módosíthatja a feladat viselkedését úgy, hogy elveti az adatkonvertálási hibákat okozó kimenetet, és továbbléphet a következőre. A sémaeltérés leggyakoribb okait az alábbiakban ismertetjük.

  • Típuseltérés: A lekérdezés és a céltípusok nem kompatibilisek. A sorok nem lesznek beszúrva a célhelyre. A lekérdezés típusainak igazításához használjon konverziós függvényt , például TRY_CAST(). Másik lehetőségként módosíthatja a céltáblát az SQL-adatbázisban.
  • Tartomány: A céltípus-tartomány jelentősen kisebb, mint a lekérdezésben használt. A tartományon kívüli értékekkel rendelkező sorokat nem lehet beszúrni a céltáblába, vagy csonk lehet csonkíteni. Érdemes lehet a céloszlopot egy nagyobb típustartományra módosítani.
  • Implicit: A lekérdezés és a céltípusok eltérőek, de kompatibilisek. Az adatok implicit módon lesznek konvertálva, de ez adatvesztéshez vagy hibákhoz vezethet. A lekérdezés típusainak igazításához vagy a céltábla módosításához használjon konverziós függvényt , például TRY_CAST().
  • Rekord: Ez a típus még nem támogatott ehhez a kimenethez. Az értéket a "rekord" sztring váltja fel. Érdemes lehet elemezni az adatokat, vagy egy UDF használatával sztringgé konvertálni.
  • Tömb: Ez a típus még nem támogatott natív módon az Azure SQL Database-ben. Az értéket a "rekord" sztring váltja fel. Érdemes lehet elemezni az adatokat, vagy egy UDF használatával sztringgé konvertálni.
  • A céltáblából hiányzó oszlop: Ez az oszlop hiányzik a céltáblából. Az adatok nem lesznek beszúrva. Szükség esetén adja hozzá ezt az oszlopot a céltáblához.

Következő lépések