Partager via

Erreurs de données Azure Stream Analytics

  • Article

Les erreurs de données sont des erreurs qui se produisent lors du traitement des données. Souvent, ces erreurs surviennent pendant les opérations de désérialisation, de sérialisation et d’écriture de données. Lorsque des erreurs de données se produisent, Stream Analytics écrit des informations détaillées et des exemples d’événements dans les journaux de diagnostic. Activez les journaux de diagnostic dans votre travail pour obtenir ces détails supplémentaires. Dans certains cas, un résumé de ces informations est également fourni par l’intermédiaire des notifications du portail.

Cet article décrit les différents types d’erreurs, leurs causes et les détails des journaux de ressources pour les erreurs de données d’entrée et de sortie.

Schéma des journaux de ressource

Pour connaître le schéma des journaux de diagnostic, consultez la section Résoudre les problèmes liés à Azure Stream Analytics à l’aide des journaux de ressources. Le code JSON suivant est un exemple de valeur pour le champ Propriétés d’un journal de ressources en cas d’erreur de données.

{
    "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
}

Erreurs de données d’entrée

InputDeserializerError.InvalidCompressionType

  • Cause : Le type de compression d’entrée sélectionné ne correspond pas aux données.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les messages avec des erreurs de désérialisation, y compris le type de compression non valide, sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée. Pour Event Hub, l’identificateur est l’ID de partition, le décalage et le numéro de séquence.

Message d’erreur

"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.InvalidHeader

  • Cause : L’en-tête de données d’entrée n’est pas valide. Par exemple, un fichier CSV comporte des colonnes avec des noms en double.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les messages avec des erreurs de désérialisation, y compris l’en-tête non valide, sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

"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

  • Cause : Les colonnes d’entrée définies avec CREATE TABLE ou par le biais TIMESTAMP BY n’existent pas.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les événements avec des colonnes manquantes sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée.
    • Noms des colonnes manquantes.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Messages d’erreur

"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

  • Cause : Impossible de convertir l’entrée selon le type spécifié dans l’instruction CREATE TABLE.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les événements avec des erreurs de conversion de type sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée.
    • Nom de la colonne et type attendu.

Messages d’erreur

"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.InvalidData

  • Cause : Les données d’entrée ne sont pas au bon format. Par exemple, l’entrée n’est pas un JSON valide.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : tous les événements dans le message, après la survenue d’une erreur de données non valide, sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Messages d’erreur

"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"

InvalidInputTimeStamp

  • Cause : La valeur de l’expression TIMESTAMP BY ne peut pas être convertie en DateHeure.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les événements avec un horodatage d’entrée non valide sont supprimés de l’entrée.
  • Détails des journaux
    • Identificateur de message d’entrée.
    • Message d’erreur.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

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

InvalidInputTimeStampKey

  • Cause : La valeur de TIMESTAMP BY OVER timestampColumn est NULL.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : les événements, avec une clé d’horodatage d’entrée non valide, sont supprimés de l’entrée.
  • Détails des journaux
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

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

LateInputEvent

  • Cause : La différence entre l’heure de l’application et l’heure d’arrivée est supérieure à la fenêtre de tolérance d’arrivée tardive.
  • Notification de portail fournie : Non
  • Niveau de journalisation de ressource : Information
  • Impact : les événements d’entrée tardifs sont traités en fonction du paramètre « Gérer les autres événements » de la section Ordre des événements dans la configuration du travail. Pour plus d’informations, consultez Stratégies de gestion du temps.
  • Détails des journaux
    • Heure de l’application et heure d’arrivée.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

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

EarlyInputEvent

  • Cause : La différence entre l’heure de l’application et l’heure d’arrivée est supérieure à 5 minutes.
  • Notification de portail fournie : Non
  • Niveau de journalisation de ressource : Information
  • Impact : les événements d’entrée précoces sont traités en fonction du paramètre « Gérer les autres événements » de la section Ordre des événements dans la configuration du travail. Pour plus d’informations, consultez Stratégies de gestion du temps.
  • Détails des journaux
    • Heure de l’application et heure d’arrivée.
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

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

OutOfOrderEvent

  • Cause : L’événement est considéré comme en désordre en raison de la fenêtre de tolérance de désordre définie.
  • Notification de portail fournie : Non
  • Niveau de journalisation de ressource : Information
  • Impact : les événements d’entrée dans le désordre sont traités en fonction du paramètre « Gérer les autres événements » de la section Ordre des événements dans la configuration du travail. Pour plus d’informations, consultez Stratégies de gestion du temps.
  • Détails des journaux
    • Charge utile réelle jusqu’à quelques kilo-octets.

Message d’erreur

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

Erreurs de données de sortie

Selon la configuration, Azure Stream Analytics peut identifier les erreurs de données de sortie avec ou sans requête d’E/S adressée au récepteur de sortie. Par exemple, l’absence d’une colonne obligatoire, telle que PartitionKey, lors de l’utilisation de la sortie de Table Azure peut être identifiée sans requête d’E/S. Toutefois, les violations de contrainte dans la sortie SQL requièrent une requête d’E/S.

Il existe plusieurs erreurs de données qui ne peuvent être détectées qu’après un appel au récepteur de sortie, ce qui peut ralentir le traitement. Pour résoudre ce problème, modifiez la configuration de votre travail ou la requête à l’origine de l’erreur de données.

OutputDataConversionError.RequiredColumnMissing

  • Cause : La colonne obligatoire pour la sortie n’existe pas. Par exemple, une colonne définie comme clé de partition de table Azure n’existe pas.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : toutes les erreurs de conversion des données de sortie, y compris la colonne nécessaire manquante, sont gérées conformément au paramètre Stratégie des données de sortie.
  • Détails des journaux
    • Nom de la colonne, et identificateur d’enregistrement ou partie de l’enregistrement.

Message d’erreur

"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.ColumnNameInvalid

  • Cause : La valeur de colonne n’est pas conforme à la sortie. Par exemple, le nom de colonne n’est pas une colonne de table Azure valide.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : toutes les erreurs de conversion des données de sortie, y compris le nom de colonne non valide, sont gérées conformément au paramètre Stratégie des données de sortie.
  • Détails des journaux
    • Nom de la colonne, et identificateur d’enregistrement ou partie de l’enregistrement.

Message d’erreur

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

OutputDataConversionError.TypeConversionError

  • Cause : Une colonne ne peut pas être convertie en un type valide dans la sortie. Par exemple, la valeur de colonne est incompatible avec les contraintes ou le type définis dans la table SQL.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : toutes les erreurs de conversion des données de sortie, y compris l’erreur de conversion du type, sont gérées conformément au paramètre Stratégie des données de sortie.
  • Détails des journaux
    • Nom de la colonne.
    • Identificateur d’enregistrement ou partie de l’enregistrement.

Message d’erreur

"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

  • Cause : La valeur du message est supérieure à la taille de sortie prise en charge. Par exemple, un enregistrement fait plus de 1 Mo pour une sortie Event Hub.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : toutes les erreurs de conversion des données de sortie, y compris l’enregistrement qui a dépassé la taille limite, sont gérées conformément au paramètre Stratégie des données de sortie.
  • Détails des journaux
    • Identificateur d’enregistrement ou partie de l’enregistrement.

Message d’erreur

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

OutputDataConversionError.DuplicateKey

  • Cause : Un enregistrement contient déjà une colonne portant le même nom qu’une colonne système. Par exemple, la sortie CosmosDB avec une colonne nommée ID lorsque la colonne d’ID est une autre colonne.
  • Notification de portail fournie : Oui
  • Niveau de journalisation de ressource : Avertissement
  • Impact : toutes les erreurs de conversion des données de sortie, y compris la clé en double, sont gérées conformément au paramètre Stratégie des données de sortie.
  • Détails des journaux
    • Nom de la colonne.
    • Identificateur d’enregistrement ou partie de l’enregistrement.
"BriefMessage": "Column 'devicePartitionKey' is being mapped to multiple columns."

Étapes suivantes