Adatok betöltése az Azure Data Explorer Go SDK használatával

Cikk
11/20/2023

Az Azure Adatkezelő egy gyors és hatékonyan skálázható adatáttekintési szolgáltatás napló- és telemetriaadatokhoz. Go SDK-ügyfélkódtárat biztosít az Azure Data Explorer szolgáltatással való interakcióhoz. A Go SDK-val betöltheti, vezérelheti és lekérdezheti az azure-Data Explorer-fürtök adatait.

Ebben a cikkben először egy táblát és egy adatleképezést hoz létre egy tesztfürtben. Ezután a Go SDK-val várólistára állíthatja a betöltéseket a fürt számára, és ellenőrizheti az eredményeket.

Előfeltételek

Microsoft-fiók vagy Microsoft Entra felhasználói identitás. Nincs szükség Azure-előfizetésre.
Egy Azure-Data Explorer-fürt és -adatbázis. Hozzon létre egy fürtöt és egy adatbázist.
Telepítse a Gitet.
Telepítse a Go-t az alábbi Go SDK minimális követelményekkel.
Hozzon létre egy alkalmazásregisztrációt, és adjon neki engedélyeket az adatbázisnak. Mentse az ügyfél-azonosítót és az ügyfélkulcsot későbbi használatra.

A Go SDK telepítése

Az Azure Data Explorer Go SDK automatikusan települ a [Go-modulokat használó mintaalkalmazás" futtatásakor. Ha egy másik alkalmazáshoz telepítette a Go SDK-t, hozzon létre egy Go modult, és kérje le az Azure Data Explorer csomagot (a használatávalgo get), például:

go mod init foo.com/bar
go get github.com/Azure/azure-kusto-go/kusto

A csomagfüggőség hozzá lesz adva a go.mod fájlhoz. Használja a Go alkalmazásban.

A kód áttekintése

Ez a Kód áttekintése szakasz nem kötelező. Ha szeretné megtudni, hogyan működik a kód, tekintse át az alábbi kódrészleteket. Ellenkező esetben továbbléphet az Alkalmazás futtatása elemre.

Hitelesítés

A művelet végrehajtása előtt a programnak hitelesítenie kell magát az Azure Data Explorer szolgáltatásban.

auth := kusto.Authorization{Config: auth.NewClientCredentialsConfig(clientID, clientSecret, tenantID)}
client, err := kusto.New(kustoEndpoint, auth)

A kusto egy példánya. Az engedélyezés a szolgáltatásnév hitelesítő adataival jön létre. Ezután létrehoz egy kusto-t. A fürtvégpontot is elfogadó Új függvénnyel rendelkező ügyfél.

Tábla létrehozása

A tábla létrehozása parancsot egy Kusto-utasítás jelöli. Az Mgmt függvény felügyeleti parancsok végrehajtására szolgál. A parancs végrehajtására szolgál egy tábla létrehozásához.

func createTable(kc *kusto.Client, kustoDB string) {
	_, err := kc.Mgmt(context.Background(), kustoDB, kusto.NewStmt(createTableCommand))
	if err != nil {
		log.Fatal("failed to create table", err)
	}
	log.Printf("Table %s created in DB %s\n", kustoTable, kustoDB)
}

Tipp

A Kusto-utasítás alapértelmezés szerint állandó a jobb biztonság érdekében. NewStmt sztringkonstansokat fogad el. Az UnsafeStmt API lehetővé teszi a nem állandó utasításszegmensek használatát, de nem ajánlott.

A Kusto create table parancs a következő:

.create table StormEvents (StartTime: datetime, EndTime: datetime, EpisodeId: int, EventId: int, State: string, EventType: string, InjuriesDirect: int, InjuriesIndirect: int, DeathsDirect: int, DeathsIndirect: int, DamageProperty: int, DamageCrops: int, Source: string, BeginLocation: string, EndLocation: string, BeginLat: real, BeginLon: real, EndLat: real, EndLon: real, EpisodeNarrative: string, EventNarrative: string, StormSummary: dynamic)

Leképezés létrehozása

Az adatleképezések a betöltés során a bejövő adatok Azure-Data Explorer-táblákban lévő oszlopokra való leképezésére szolgálnak. További információ: adatleképezés. A leképezés ugyanúgy jön létre, mint egy tábla, az Mgmt adatbázis nevével és a megfelelő paranccsal. A teljes parancs a minta GitHub-adattárában érhető el.

func createMapping(kc *kusto.Client, kustoDB string) {
	_, err := kc.Mgmt(context.Background(), kustoDB, kusto.NewStmt(createMappingCommand))
	if err != nil {
		log.Fatal("failed to create mapping - ", err)
	}
	log.Printf("Mapping %s created\n", kustoMappingRefName)
}