如何解决无法将错误的记录插入SNS
我正在使用AWS Lambda,并想为失败事件记录配置目标。但是,当我使用本地堆栈进行操作并发送错误的记录时,它并没有将其插入配置的目标位置,即SNS。
我指的是此链接- https://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-errors
随附的是我的代码和创建lambda的步骤-
- 创建lambda函数:
awslocal lambda create-function --function-name FunctionName --runtime python3.8 --role admin --handler app.execute --zip-file fileb://development.zip
awslocal lambda create-event-source-mapping --function-name FunctionName \
--event-source arn:aws:kinesis:us-east-1:xxxxxxxxxxxx:stream/develop_feed \
--batch-size 1 --starting-position LATEST --destination-config '{"OnFailure":{"Destination": "arn:aws:sqs:us-east-1:xxxxxxxxxxxx:error_messages"}}'
awslocal lambda update-function-configuration --function-name FunctionName \
--environment "Variables={TO_FILTER_PARAMETERS=operation,KINESIS_ENDPOINT_URL='http://<ip>:<port>',OUTPUT_STREAM=filtered_feed,LOG_LEVEL=DEBUG,ERROR_STREAM='error_feed'}"
唯一的变化是:
awslocal lambda update-function-code --function-name FunctionName --zip-file fileb://development.zip
- 要列出:
awslocal lambda list-functions
awslocal kinesis list-streams
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。