go - 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)
}
解决方案
AWS lambda 函数是一个无状态函数,您可以在此处找到更多信息:https ://blog.checkpoint.com/2020/03/18/aws-lambda-stateless-ephemeral/ ,因此有关变量、对象等的信息是函数运行后丢失并在下一次启动时重新开始。要在无状态环境中实现 CB,您必须将函数调用的状态存储在外部数据库/缓存等中(对于 aws,它可能是 dynamoDb 表、Elasticache redis、SNS 队列等)。所以有可能做到这一点,但它有点扭曲。
推荐阅读
- java - 根据坐标占位符替换 PDF 中的字符串/行并使用 java 重新对齐 PDF 的内容
- ios - 使用 PHImageManager 时,PHAsset 返回 UIImage 的 nil 值
- python - 如何将 cumcount 应用于两列?
- c# - 如何在瓷砖地图中动态设置瓷砖?
- c++ - spoj SEQ - 递归序列运行时错误
- javascript - 需要帮助单击没有任何标识符的 ``` ``` 元素
- c# - 禁止在文本框中输入无效字符列表的自定义验证属性
- c# - iOS 13 中的 Xamarin 基本共享
- php - php mysqli 表单 - 从选择下拉更新中填写输入
- php - 我该怎么做preg_replace?