今天我给大家带来一篇《AWS Lambda 的断路器》,本文主要会讲到等等知识点,希望大家一起学习进步,也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧!
问题内容
是否可以使用像 Gobreaker 这样的断路器库将 Http 请求包装在 lambda 处理程序中,我正在尝试类似下面的操作,但没有看到计数超过 1。也许 aws lambda 不可能?我已使用 sam 进行本地测试并部署在 aws 上。
func handler(ctx context.Context, request events.ALBTargetGroupRequest) (events.ALBTargetGroupResponse, error) {
resp, errBreaker := cb.Execute(func() (interface{}, error) {
return sendHttpRequestThatFails(request, ctx)
})
if errBreaker != nil {
log.Fatal("Error Breaker:", errBreaker)
}
return resp.(events.ALBTargetGroupResponse), nil
}
func main() {
//global config added to global circuit breaker variable
var st gobreaker.Settings
st.Name = "HTTP POST Breaker"
st.Timeout = 2
st.OnStateChange = func(name string, from gobreaker.State, to gobreaker.State) {
// do smth when circuit breaker trips.
log.Info("tripped breaker name : "+name+" from "+from.String() + " to "+to.String())
}
st.ReadyToTrip = func(counts gobreaker.Counts) bool {
log.Info("counts ,",counts )
return counts.TotalFailures >= 2 // I never see this count go over 1
}
cb = gobreaker.NewCircuitBreaker(st)
nrlambda.Start(handler, app)
}
解决方案
我在这里回答我自己的问题,因为我发现是什么导致计数保持在 1 并且不增加,log.fatal 代码行终止了 Lambda 函数的执行并清除所有 go 断路器计数,并且状态。删除此函数,函数完成,并且是可行的实例,可以由 AWS 保温。
AWS lambda 函数是无状态函数,您可以在此处找到更多信息:https://blog.checkpoint.com/2020/03/18/aws-lambda-stateless-ephemeral/,因此有关变量、对象等的信息在函数运行后丢失并在下次启动时重新开始。 要在无状态环境中实现 CB,您必须将函数调用的状态存储在外部数据库/缓存等中(对于 aws,它可能是 dynamoDb 表、Elasticache Redis、SNS 队列等)。所以这是可能做到的,但它有一点曲折。