Parameter yang diperlukan untuk transformasi data - Amazon Data Firehose

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Parameter yang diperlukan untuk transformasi data

Semua catatan yang diubah dari Lambda harus berisi parameter berikut, atau Amazon Data Firehose menolaknya dan memperlakukannya sebagai kegagalan transformasi data.

For Kinesis Data Streams and Direct PUT

Parameter berikut diperlukan untuk semua catatan yang diubah dari Lambda.

  • recordId— ID rekaman diteruskan dari Amazon Data Firehose ke Lambda selama pemanggilan. Catatan yang ditransformasi harus berisi ID catatan yang sama. Ketidakcocokan apa pun antara ID catatan asli dan ID catatan yang ditransformasi dianggap sebagai kegagalan transformasi data.

  • result— Status transformasi data catatan. Kemungkinan nilainya adalah: Ok (catatan berhasil ditransformasi), Dropped (catatan dihentikan dengan sengaja oleh logika pemrosesan Anda), dan ProcessingFailed (catatan tidak bisa ditransformasi). Jika rekaman memiliki status Ok atauDropped, Amazon Data Firehose menganggapnya berhasil diproses. Jika tidak, Amazon Data Firehose menganggapnya tidak berhasil diproses.

  • data— Payload data yang diubah, setelah pengkodean base64.

    Berikut ini adalah contoh hasil keluaran Lambda:

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

Parameter berikut diperlukan untuk semua catatan yang diubah dari Lambda.

  • recordId— ID rekaman diteruskan dari Firehose ke Lambda selama pemanggilan. Catatan yang ditransformasi harus berisi ID catatan yang sama. Ketidakcocokan apa pun antara ID catatan asli dan ID catatan yang ditransformasi dianggap sebagai kegagalan transformasi data.

  • result— Status transformasi data catatan. Kemungkinan nilainya adalah: Ok (catatan berhasil ditransformasi), Dropped (catatan dihentikan dengan sengaja oleh logika pemrosesan Anda), dan ProcessingFailed (catatan tidak bisa ditransformasi). Jika rekaman memiliki status Ok atauDropped, Firehose menganggapnya berhasil diproses. Jika tidak, Firehose menganggapnya tidak berhasil diproses.

  • KafkaRecordValue— Payload data yang diubah, setelah pengkodean base64.

    Berikut ini adalah contoh hasil keluaran Lambda:

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