Azure Stream Analytics veri hataları

  • Makale
  • Okumak için 6 dakika

Veri hataları, verileri işlerken oluşan hatalardır. Bu hatalar genellikle veri serileştirme, serileştirme ve yazma işlemleri sırasında oluşur. Veri hataları oluştuğunda, Stream Analytics ayrıntılı bilgileri ve örnek olayları kaynak günlüklerine yazar. Bu ek ayrıntıları almak için işinizdeki tanılama günlüklerini etkinleştirin. Bazı durumlarda, bu bilgilerin Özeti Portal bildirimleri aracılığıyla da sağlanır.

Bu makalede, giriş ve çıkış verileri hatalarına yönelik farklı hata türleri, nedenler ve kaynak günlüğü ayrıntıları özetlenmektedir.

Kaynak günlükleri şeması

Kaynak günlüklerinin şemasını görmek için tanılama günlüklerini kullanarak Azure Stream Analytics sorun giderme bölümüne bakın. Aşağıdaki JSON, bir veri hatası için kaynak günlüğünün Özellikler alanı için örnek bir değerdir.

{
    "Source": "InputTelemetryData",
    "Type": "DataError",
    "DataErrorType": "InputDeserializerError.InvalidData",
    "BriefMessage": "Json input stream should either be an array of objects or line separated objects. Found token type: Integer",
    "Message": "Input Message Id: https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt Error: Json input stream should either be an array of objects or line separated objects. Found token type: Integer",
    "ExampleEvents": "[\"1,2\\\\u000d\\\\u000a3,4\\\\u000d\\\\u000a5,6\"]",
    "FromTimestamp": "2019-03-22T22:34:18.5664937Z",
    "ToTimestamp": "2019-03-22T22:34:18.5965248Z",
    "EventCount": 1
}

Giriş verileri hataları

Inputdeserializererror. ınvalidcompressiontype

  • Neden: seçilen giriş sıkıştırma türü verilerle eşleşmiyor.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: Geçersiz sıkıştırma türü de dahil olmak üzere herhangi bir seri kaldırma hatası içeren Iletiler girişten bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı. Olay Hub 'ı için, tanımlayıcı PartitionID, konum ve sıra numarasıdır.

Hata iletisi

"BriefMessage": "Unable to decompress events from resource 'https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt'. Please ensure compression setting fits the data being processed."

Inputdeserializererror. ınvalidheader

  • Neden: giriş verilerinin üstbilgisi geçersiz. Örneğin, bir CSV yinelenen adlara sahip sütunlara sahiptir.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: geçersiz üst bilgi dahil olmak üzere herhangi bir seri kaldırma hatası içeren Iletiler girişten bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı.
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"BriefMessage": "Invalid CSV Header for resource 'https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt'. Please make sure there are no duplicate field names."

Inputdeserializererror. MissingColumns

  • Neden: CREATE TABLE veya ile zaman DAMGASı aracılığıyla tanımlanan giriş sütunları yok.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: eksik sütunları olan olaylar girişten bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı.
    • Eksik olan sütunların adları.
    • En fazla bir kilobayt kadar gerçek yük.

Hata iletileri

"BriefMessage": "Could not deserialize the input event(s) from resource 'https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt' as Csv. Some possible reasons: 1) Malformed events 2) Input source configured with incorrect serialization format" 

"Message": "Missing fields specified in query or in create table. Fields expected:ColumnA Fields found:ColumnB"

Inputdeserializererror. TypeConversionError

  • Neden: giriş, CREATE TABLE ifadesinde belirtilen türe dönüştürülemedi.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: tür dönüştürme hatası olan olaylar girişten bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı.
    • Sütunun adı ve beklenen tür.

Hata iletileri

"BriefMessage": "Could not deserialize the input event(s) from resource '''https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt ' as Csv. Some possible reasons: 1) Malformed events 2) Input source configured with incorrect serialization format" 

"Message": "Unable to convert column: dateColumn to expected type."

Inputdeserializererror. ınvaliddata

  • Neden: giriş verileri doğru biçimde değil. Örneğin, giriş geçerli bir JSON değil.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: geçersiz bir veri hatası ile karşılaşıldıktan sonra iletideki tüm olaylara giriş işleminden bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı.
    • En fazla kilobayt olan gerçek yük.

Hata iletileri

"BriefMessage": "Json input stream should either be an array of objects or line separated objects. Found token type: String"

"Message": "Json input stream should either be an array of objects or line separated objects. Found token type: String"

Invalidınputtimestamp

  • Neden: ifadeye göre zaman DAMGASı değeri DateTime değerine dönüştürülemez.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: geçersiz giriş zaman damgasına sahip olaylar girişten bırakılır.
  • Günlük ayrıntıları
    • Giriş iletisi tanımlayıcısı.
    • Hata iletisi.
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"BriefMessage": "Unable to get timestamp for resource 'https:\\/\\/exampleBlob.blob.core.windows.net\\/inputfolder\\/csv.txt ' due to error 'Cannot convert string to datetime'"

Invalidınputtimestamp anahtarı

  • Neden: TIMESTAMP sütununun ÜZERINDE zaman damgası değeri NULL.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: geçersiz giriş zaman damgası anahtarına sahip olaylar girişten bırakılır.
  • Günlük ayrıntıları
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"BriefMessage": "Unable to get value of TIMESTAMP BY OVER COLUMN"

Lateınputevent

  • Neden: uygulama süresi ve varış süresi arasındaki fark geç varış toleransı penceresinden daha büyüktür.
  • Portal bildirimi belirtildi: Hayır
  • Kaynak günlük düzeyi: bilgi
  • Etki: geç giriş olayları, iş yapılandırmasının olay sıralaması bölümünde "diğer olayları Işleme" ayarına göre işlenir. Daha fazla bilgi için bkz. zaman Işleme ilkeleri.
  • Günlük ayrıntıları
    • Uygulama süresi ve varış süresi.
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"BriefMessage": "Input event with application timestamp '2019-01-01' and arrival time '2019-01-02' was sent later than configured tolerance."

Earlyınputevent

  • Neden: uygulama süresi ve varış süresi arasındaki fark 5 dakikadan fazla.
  • Portal bildirimi belirtildi: Hayır
  • Kaynak günlük düzeyi: bilgi
  • Etki: erken giriş olayları, iş yapılandırmasının olay sıralaması bölümünde "diğer olayları Işleme" ayarına göre işlenir. Daha fazla bilgi için bkz. zaman Işleme ilkeleri.
  • Günlük ayrıntıları
    • Uygulama süresi ve varış süresi.
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"BriefMessage": "Input event arrival time '2019-01-01' is earlier than input event application timestamp '2019-01-02' by more than 5 minutes."

OutOfOrderEvent

  • Neden: olay, sıralama dışı tolerans penceresi tanımlı olarak kabul edilir.
  • Portal bildirimi belirtildi: Hayır
  • Kaynak günlük düzeyi: bilgi
  • Etki: sıra dışı olaylar, iş yapılandırmasının olay sıralaması bölümünde "diğer olayları Işleme" ayarına göre işlenir. Daha fazla bilgi için bkz. zaman Işleme ilkeleri.
  • Günlük ayrıntıları
    • En fazla kilobayt olan gerçek yük.

Hata iletisi

"Message": "Out of order event(s) received."

Çıkış verileri hataları

Azure Stream Analytics, yapılandırmaya bağlı olarak çıkış havuzunda g/ç isteği ile veya olmayan çıkış verileri hatalarını tanımlayabilir. Örneğin, PartitionKey Azure Tablo çıkışı kullanılırken, bir g/ç isteği olmadan bir gerekli sütun eksik olabilir. Ancak, SQL çıktısında kısıtlama ihlalleri bir g/ç isteği gerektirir.

Yalnızca çıkış havuzuna bir çağrı yapıldıktan sonra algılanamayan ve işlemeyi yavaşlatabilecek birkaç veri hatası vardır. Bu sorunu çözmek için, işinizin yapılandırmasını veya veri hatasına neden olan sorguyu değiştirin.

OutputDataConversionError. RequiredColumnMissing yok

  • Neden: çıktı için gereken sütun yok. Örneğin, Azure Table PartitionKey olarak tanımlanan bir sütun yok.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: eksik gerekli sütununu da içeren tüm çıkış verileri dönüştürme hataları çıkış verileri ilkesi ayarına göre işlenir.
  • Günlük ayrıntıları
    • Sütunun adı ve kayıt tanımlayıcısı ya da kaydın bir parçası.

Hata iletisi

"Message": "The output record does not contain primary key property: [deviceId] Ensure the query output contains the column [deviceId] with a unique non-empty string less than '255' characters."

OutputDataConversionError. Columnnamegeçersiz

  • Neden: sütun değeri çıkışa uymuyor. Örneğin, sütun adı geçerli bir Azure Tablo sütunu değil.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: geçersiz sütun adı da dahil olmak üzere tüm çıkış verileri dönüştürme hataları çıkış verileri ilkesi ayarına göre işlenir.
  • Günlük ayrıntıları
    • Sütunun adı ve kayıt tanımlayıcı ya da kaydın bir parçası.

Hata iletisi

"Message": "Invalid property name #deviceIdValue. Please refer MSDN for Azure table property naming convention."

OutputDataConversionError. TypeConversionError

  • Neden: bir sütun çıktıda geçerli bir türe dönüştürülemez. Örneğin, sütununun değeri SQL tablosunda tanımlı kısıtlamalar veya türle uyumlu değil.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: tür dönüştürme hatası da dahil olmak üzere tüm çıkış verileri dönüştürme hataları çıkış verileri ilkesi ayarına göre işlenir.
  • Günlük ayrıntıları
    • Sütunun adı.
    • Kayıt tanımlayıcı ya da kaydın bir parçası.

Hata iletisi

"Message": "The column [id] value null or its type is invalid. Ensure to provide a unique non-empty string less than '255' characters."

OutputDataConversionError. RecordExceededSizeLimit

  • Neden: iletinin değeri desteklenen çıkış boyutundan daha büyük. Örneğin, bir kayıt bir olay hub 'ı çıkışı için 1 MB 'den büyük.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: kayıt boyutu sınırı da dahil olmak üzere tüm çıkış verileri dönüştürme hataları, çıkış verileri ilkesi ayarına göre işlenir.
  • Günlük ayrıntıları
    • Kayıt tanımlayıcı ya da kaydın bir parçası.

Hata iletisi

"BriefMessage": "Single output event exceeds the maximum message size limit allowed (262144 bytes) by Event Hub."

OutputDataConversionError. DuplicateKey

  • Neden: bir kayıt zaten sistem sütunuyla aynı ada sahip bir sütun içeriyor. Örneğin, ID sütunu farklı bir sütuna ayarlandığında ID adlı bir sütunla CosmosDB çıkışı.
  • Portal bildirimi belirtildi: Evet
  • Kaynak günlük düzeyi: uyarı
  • Etki: yinelenen anahtar dahil tüm çıkış verileri dönüştürme hataları çıkış verileri ilkesi ayarına göre işlenir.
  • Günlük ayrıntıları
    • Sütunun adı.
    • Kayıt tanımlayıcı ya da kaydın bir parçası.
"BriefMessage": "Column 'devicePartitionKey' is being mapped to multiple columns."

Sonraki adımlar