Paramètres requis pour la transformation des données - Amazon Data Firehose

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Paramètres requis pour la transformation des données

Tous les enregistrements transformés depuis Lambda doivent contenir les paramètres suivants, sinon Amazon Data Firehose les rejette et considère cela comme un échec de transformation des données.

For Kinesis Data Streams and Direct PUT

Les paramètres suivants sont obligatoires pour tous les enregistrements transformés à partir de Lambda.

  • recordId— L'ID d'enregistrement est transmis d'Amazon Data Firehose à Lambda lors de l'appel. L'enregistrement transformé doit comporter le même ID d'enregistrement. La moindre incohérence entre l'ID de l'enregistrement initial et l'ID de l'enregistrement transformé est traitée comme un échec de la transformation des données.

  • result— État de la transformation des données de l'enregistrement. Les valeurs possibles sont : Ok (l'enregistrement a été transformé), Dropped (l'enregistrement a été abandonné de manière intentionnelle par votre logique de traitement) et ProcessingFailed (impossible de transformer l'enregistrement). Si un enregistrement a le statut Ok ouDropped, Amazon Data Firehose considère qu'il a été traité avec succès. Dans le cas contraire, Amazon Data Firehose considère qu'il n'a pas été traité correctement.

  • data— La charge utile des données transformées, après le codage en base64.

    Voici un exemple de résultat Lambda :

     {
    "recordId": "<recordId from the Lambda input>",
    "result": "Ok",
    "data": "<Base64 encoded Transformed data>"
}
For Amazon MSK

Les paramètres suivants sont obligatoires pour tous les enregistrements transformés à partir de Lambda.

  • recordId— L'ID d'enregistrement est transmis de Firehose à Lambda lors de l'invocation. L'enregistrement transformé doit comporter le même ID d'enregistrement. La moindre incohérence entre l'ID de l'enregistrement initial et l'ID de l'enregistrement transformé est traitée comme un échec de la transformation des données.

  • result— État de la transformation des données de l'enregistrement. Les valeurs possibles sont : Ok (l'enregistrement a été transformé), Dropped (l'enregistrement a été abandonné de manière intentionnelle par votre logique de traitement) et ProcessingFailed (impossible de transformer l'enregistrement). Si un enregistrement a le statut Ok ouDropped, Firehose considère qu'il a été traité avec succès. Dans le cas contraire, Firehose considère qu'il n'a pas été traité correctement.

  • KafkaRecordValue— La charge utile des données transformées, après le codage en base64.

    Voici un exemple de résultat Lambda :

     {
    "recordId": "<recordId from the Lambda input>",
    "result": "Ok",
    "kafkaRecordValue": "<Base64 encoded Transformed data>"
}