适用于AWS Lambda的断路器

问题描述

是否可以使用gobreaker之类的Circuit-Breaker库在lambda处理程序中包装HTTP请求，我正在尝试类似以下内容，但看不到计数超过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)
 }

解决方法

AWS lambda函数是无状态函数，您可以在此处找到更多信息：https://blog.checkpoint.com/2020/03/18/aws-lambda-stateless-ephemeral/，因此有关变量，对象等的信息在函数运行后会丢失，并在下次启动时重新开始。 要在无状态环境中实现CB，您必须将函数调用的状态存储在外部数据库/缓存等中（对于aws，它可能是dynamoDb表，Elasticache redis，SNS队列等）。因此有可能做到这一点，但这有点曲折。

,

我在这里回答我自己的问题，因为我发现导致计数保持为1而不是递增的原因是，log.fatal代码行杀死了Lambda函数的执行并清除了所有go语句计数和状态。删除它，函数完成，并且是可用的实例，可以由AWS保持温暖。