如何丢弃记录？

Question

我将事件发送到AWS Kinesis，这些事件由AWS lambda函数处理。但是，如果lambda抛出一些错误，则不会丢弃记录，并且会一次又一次地进行处理，从而阻止处理新记录。

我宁愿跳过错误的记录，消化新的记录。我不知道该怎么做。

lambda函数捕获任何异常，因此不应给出任何执行错误。

下面是python中的片段。

我知道lambda应该在“保留”期间重试（默认为24小时），但我希望放弃并最终记录任何类型的错误

def ProcessKinesisRecords(event, context):
    body = "ok"   
    response_code = 200
    for record in event['Records']:
        # Kinesis data is base64 encoded so decode here
        try:
            payload = base64.b64decode(record["kinesis"]["data"])
            #...payload processing
        except Exception as e:
            body = e 

    return {"isBase64Encoded": True, "statusCode": response_code, "headers": { "x-custom-header": "headerValue" }, "body": body}

我想我遵循了lambda重试...但我不明白我做错了什么

Answer 1

实际上，我并没有捕捉到所有的异常。在python中

except Exception as e:

没有捕获所有异常：在Python中，除了：和除了异常之间的区别为e：

它不会捕获BaseException或系统退出异常SystemExit、KeyboardInterrupt和GeneratorExit。这就是为什么它不起作用。