python - 您可以创建自定义 AWS Kinesis 错误输出类型吗?
问题描述
我正在使用 AWS Kinesis Firehose 流来摄取数据,然后使用 lambda 函数在写入 S3 存储桶之前进行架构验证和数据转换。我之前一直将不正确记录的状态设置为 ProcessingFailed 并将这些错误写入{stream_id}/errors/{timestamp}/processing-failed
文件夹,但该方法会写入自动生成的错误响应:
{
"attemptsMade": "1",
"arrivalTimestamp": "timestamp",
"errorCode": "Lambda.ProcessingFailedStatus",
"errorMessage": "ProcessingFailed status set for record",
"attemptEndingTimestamp": "timestamp",
"rawData": "data example",
"lambdaArn": "arn"
}
是否可以创建一个自定义错误输出类型,该类型将写入{stream_id}/errors/{timestamp}/custom-error
,带有自定义错误消息和看起来更像这样的字段?
{
"errorCode": "ValidationFailedStatus",
"errorMessage": "Validation failed because 'state' was not present in data"
}
我想另一种选择是使用动态分区。
解决方案
推荐阅读
- javascript - 如何通过ajax将两个数组发送到控制器
- android - Kotlin Android 搜索菜单项在活动开始时聚焦
- python - 绘制一个强度下降的非增长圆
- r - 获取比较多列的单列值
- excel - 从 Excel 调用 Access 函数
- lua - 为什么这个lua变量是nil,如果赋值语句后跟一个“,”
- c++ - 带有指针和 const 方法的类
- python - 如果将在 Python 中使用该类的实例,我是否必须导入该类?
- javascript - react-i18next:如何同步浏览器和 Express LanguageDetector?
- html - 即使向右浮动,元素也会向左移动