AWS Lambda 断路器

Question

是否可以使用像 gobreaker 这样的断路器库在 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)
 }

Answer 1

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

Answer 2

我在这里回答我自己的问题，因为我发现是什么导致计数保持在 1 而不是递增，log.fatal 代码行终止了 Lambda 函数的执行并清除了所有去断路器计数和状态。删除它，函数完成并且是 AWS 保暖的可行实例。

AWS Lambda 断路器

Circuit Breaker for AWS Lambda

go

circuit-breaker

aws-lambda