AWS Lambda 断路器

是否可以使用像 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)

 }


天涯尽头无女友
浏览 94回答 2
2回答

ITMISS

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

POPMUISE

我在这里回答我自己的问题,因为我发现是什么导致计数保持在 1 并且不增加,log.fatal代码行正在终止 Lambda 函数的执行并清除所有 go 断路器计数和状态。删除它,函数完成并成为 AWS 保温的可行实例。
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Go