Parâmetros necessários para transformação de dados

recordId: o ID do registro é transmitido do Amazon Data Firehose para o Lambda durante a invocação. O registro transformado deve conter o mesmo ID de registro. Qualquer incompatibilidade entre o ID do registro original e o ID do registro transformado é considerada uma falha na transformação de dados.

result: o status da transformação de dados do registro. Os valores possíveis são: Ok (o registro foi transformado com êxito), Dropped (o registro foi removido intencionalmente pela lógica de processamento), e ProcessingFailed (não foi possível transformar o registro). Se um registro tiver um status de Ok ou Dropped, o Amazon Data Firehose considerará o processamento com êxito. Caso contrário, o Amazon Data Firehose considerará que o processamento do registro não teve êxito.

data: a carga útil dos dados transformados, após a codificação base64.

Este é um exemplo de saída de resultados do Lambda:

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

recordId: o ID do registro é transmitido do Firehose para o Lambda durante a invocação. O registro transformado deve conter o mesmo ID de registro. Qualquer incompatibilidade entre o ID do registro original e o ID do registro transformado é considerada uma falha na transformação de dados.

result: o status da transformação de dados do registro. Os valores possíveis são: Ok (o registro foi transformado com êxito), Dropped (o registro foi removido intencionalmente pela lógica de processamento), e ProcessingFailed (não foi possível transformar o registro). Se um registro tiver o status Ok ou Dropped, o Firehose considerará que processamento teve êxito. Caso contrário, o Firehose considerará que o processamento do registro não teve êxito.

KafkaRecordValue: a carga útil dos dados transformados, após a codificação base64.

Este é um exemplo de saída de resultados do Lambda:

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