Alım eşlemeleri

Şunlar için geçerlidir: ✅Microsoft Fabric✅Azure Veri Gezgini

Alma eşlemeleri, gelen verileri tabloların içindeki sütunlara eşlemek için alım sırasında kullanılır.

Veri Gezgini hem satır odaklı (CSV, JSON, AVRO ve W3CLOGFILE) hem de sütun odaklı (Parquet ve ORC) farklı eşleme türlerini destekler.

Alma eşlemeleri alma komutunda tanımlanabilir veya önceden oluşturulmuş ve ingestionMappingReference parametreleri kullanılarak alma komutundan başvurulabilir. Alma işlemi, eşleme belirtilmeden mümkündür. Daha fazla bilgi için bkz . Kimlik eşleme.

Eşleme listesindeki her öğe üç alandan oluşturulur:

Desteklenen eşleme türleri

Aşağıdaki tablo, belirli bir biçimdeki dış verileri alırken veya sorgularken kullanılacak eşleme türlerini tanımlar.

Alım eşleme örnekleri

Aşağıdaki örneklerde aşağıdaki şemaya sahip RawEvents tablosu kullanılır:

.create table RawEvents (timestamp: datetime, deviceId: guid, messageId: guid, temperature: decimal, humidity: decimal) 

Basit eşleme

Aşağıdaki örnekte, alma komutunda eşlemenin tanımlandığı alma işlemi gösterilmektedir. komutu url'den RawEvents tablosuna bir JSON dosyası alır. Eşleme, JSON dosyasındaki her alanın yolunu belirtir.

.ingest into table RawEvents ('https://kustosamplefiles.blob.core.windows.net/jsonsamplefiles/simple.json') 
    with (
            format = "json",
            ingestionMapping =
            ```
            [ 
              {"column":"timestamp","Properties":{"path":"$.timestamp"}},
              {"column":"deviceId","Properties":{"path":"$.deviceId"}},
              {"column":"messageId","Properties":{"path":"$.messageId"}},
              {"column":"temperature","Properties":{"path":"$.temperature"}},
              {"column":"humidity","Properties":{"path":"$.humidity"}}
            ]
            ```
          )

ingestionMappingReference ile eşleme

Önceden oluşturulmuş eşleme kullanarak aynı JSON dosyasını eşlemek için aşağıdaki komutla RawEventMapping alma eşleme başvurusunu oluşturun:

.create table RawEvents ingestion json mapping 'RawEventMapping' 
  ```
  [ 
    {"column":"timestamp","Properties":{"path":"$.timestamp"}},
    {"column":"deviceId","Properties":{"path":"$.deviceId"}},
    {"column":"messageId","Properties":{"path":"$.messageId"}},
    {"column":"temperature","Properties":{"path":"$.temperature"}},
    {"column":"humidity","Properties":{"path":"$.humidity"}}
  ]
  ```

Aşağıdaki komutla RawEventMapping alma eşleme başvurusunu kullanarak JSON dosyasını alın:

.ingest into table RawEvents ('https://kustosamplefiles.blob.core.windows.net/jsonsamplefiles/simple.json') 
  with (
          format="json",
          ingestionMappingReference="RawEventMapping"
        )

Kimlik eşleme

veya ingestionMapping özellikleri belirtilmeden ingestionMappingReference alma mümkündür. Veriler, tablonun şemasından türetilen bir kimlik veri eşlemesi kullanılarak eşlenir. Tablo şeması aynı kalır. format özelliği belirtilmelidir. Bkz . alma biçimleri.

Eşleme dönüştürmeleri

Veri biçimi eşlemelerinden bazıları (Parquet, JSON ve AVRO), basit ve kullanışlı alma zamanı dönüştürmelerini destekler. Senaryonun alma zamanında daha karmaşık işleme gerektirdiği durumlarda, KQL ifadesi kullanarak basit işleme tanımlamaya olanak tanıyan Güncelleştirme ilkesini kullanın.

Eşleme dönüştürme örnekleri

DropMappedFields dönüşüm:

Aşağıdaki JSON içeriği göz önünde bulundurulduğunda:

{
    "Time": "2012-01-15T10:45",
    "Props": {
        "EventName": "CustomEvent",
        "Revenue": 0.456
    }
}

Aşağıdaki veri eşlemesi, zaten eşlenmiş sütunları dışlarken nesnenin tamamını Props dinamik sütuna Props eşler (Props.EventName zaten sütuna EventNameeşlenir, bu nedenle dışlanır).

[
    { "Column": "Time", "Properties": { "Path": "$.Time" } },
    { "Column": "EventName", "Properties": { "Path": "$.Props.EventName" } },
    { "Column": "Props", "Properties": { "Path": "$.Props", "Transform":"DropMappedFields" } },
]

Alınan veriler aşağıdaki gibi görünür:

BytesAsBase64 dönüşüm

Aşağıdaki AVRO dosyası içeriği göz önünde bulundurulduğunda:

{
    "Time": "2012-01-15T10:45",
    "Props": {
        "id": [227,131,34,92,28,91,65,72,134,138,9,133,51,45,104,52]
    }
}

Aşağıdaki veri eşlemesi, kimlik sütununu dönüştürmeyle ve dönüştürme olmadan iki kez eşler.

[
    { "Column": "ID", "Properties": { "Path": "$.props.id" } },
    { "Column": "Base64EncodedId", "Properties": { "Path": "$.props.id", "Transform":"BytesAsBase64" } },
]

Alınan veriler aşağıdaki gibi görünür: