Fabric-jegyzetfüzetek használata KQL-adatbázisból származó adatokkal

A jegyzetfüzetek olvasható dokumentumok, amelyek adatelemzési leírásokat és eredményeket, valamint végrehajtható dokumentumokat tartalmaznak, amelyek az adatelemzés végrehajtásához futtathatók. Ebből a cikkből megtudhatja, hogyan csatlakozhat egy Fabric-jegyzetfüzethez egy KQL-adatbázis adataihoz, és hogyan futtathat lekérdezéseket natív KQL (Kusto Query Language)használatával. További információ a jegyzetfüzetekről: Microsoft Fabric-jegyzetfüzetek használata.

A Fabric-jegyzetfüzetek kétféleképpen használhatók a KQL-adatbázisból származó adatokkal:

• Kusto-kódrészletek használata jegyzetfüzetben
• Jegyzetfüzet létrehozása KQL-adatbázisból

Előfeltételek

• munkaterület Microsoft Fabric-kompatibilis kapacitással
• Legalább megtekintési engedélyekkel rendelkező KQL-adatbázis

Kusto-kódrészletek használata jegyzetfüzetben

A Fabric jegyzetfüzetek kódrészleteket tartalmaznak, amelyek megkönnyítik a gyakran használt kódminták írását. A KQL-adatbázis adatainak írásához vagy olvasásához kódrészleteket használhat KQL használatával.

1. Lépjen egy meglévő jegyzetfüzetre, vagy hozzon létre egy újat.

2. Egy kódcellában kezdje el beírni kusto.

   

3. Válassza ki a végrehajtani kívánt műveletnek megfelelő kódrészletet: Adatok írása KQL-adatbázisba vagy Adatok beolvasása KQL-adatbázisból.

   Az alábbi kódrészlet a példa adatolvasási műveletet mutatja be:

   # Example of query for reading data from Kusto. Replace T with your <tablename>.
   kustoQuery = "['T'] | take 10"
   # The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com.
   kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com"
   # The database with data to be read.
   database = "DocsDatabase"
   # The access credentials.
   accessToken = mssparkutils.credentials.getToken('kusto')
   kustoDf  = spark.read\
       .format("com.microsoft.kusto.spark.synapse.datasource")\
       .option("accessToken", accessToken)\
       .option("kustoCluster", kustoUri)\
       .option("kustoDatabase", database)\
       .option("kustoQuery", kustoQuery).load()
   
   # Example that uses the result data frame.
   kustoDf.show()
   

   Az alábbi kódrészlet a példa adatírási műveletet mutatja be:

   # The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com 
   kustoUri = ""
   # The database to write the data
   database = ""
   # The table to write the data 
   table    = ""
   # The access credentials for the write
   accessToken = mssparkutils.credentials.getToken('kusto')
   
   # Generate a range of 5 rows with Id's 5 to 9
   data = spark.range(5,10) 
   
   # Write data to a Kusto table
   data.write.\
   format("com.microsoft.kusto.spark.synapse.datasource").\
   option("kustoCluster",kustoUri).\
   option("kustoDatabase",database).\
   option("kustoTable", table).\
   option("accessToken", accessToken ).\
   option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()
   

4. Adja meg a szükséges információkat az adatcella egyes mezőinek idézőjelei között:

   Mező	Leírás	Kapcsolódó hivatkozások
   kustoQuery	A kiértékelendő KQL-lekérdezés.	KQL áttekintése
   KustoUri	A KQL-adatbázis lekérdezési URI-ja.	KQL-adatbázis URI másolása
   adatbázis	A KQL-adatbázis neve.	Meglévő KQL-adatbázis elérése
   adat	A táblába írandó adatok.

5. Futtassa a kódcellát.

Jegyzetfüzet létrehozása KQL-adatbázisból

Amikor egy jegyzetfüzetet kapcsolódó elemként hoz létre egy KQL-adatbázisban, a jegyzetfüzet neve megegyezik a KQL-adatbázis nevével, és a kapcsolati adatokkal együtt előre fel van töltve.

1. Keresse meg a KQL-adatbázist.

2. Válassza ki a Új kapcsolódó elem>Jegyzetfüzet.

   

   A rendszer létrehoz egy jegyzetfüzetet a KustoUri-val és az adatbázis adataival előre feltöltve.

3. Adja meg a kiértékelendő KQL-lekérdezést a kustoQuery mezőben.

   

4. Futtassa a kódcellát.

Kapcsolódó tartalom

• KQL áttekintése
• Microsoft Fabric-jegyzetfüzetek használata