Ceilometer项目源码分析----ceilometer报警器状态评估方式之单一报警器状态评估的具体实现

设计模式 前端之家
前端之家收集整理的这篇文章主要介绍了Ceilometer项目源码分析----ceilometer报警器状态评估方式之单一报警器状态评估的具体实现，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

感谢朋友支持本博客，欢迎共同探讨交流，由于能力和时间有限，错误之处在所难免，欢迎指正！

如果转载，请保留作者信息。
博客地址：http://blog.csdn.net/gaoxingnengjisuan
邮箱地址：dong.liu@siat.ac.cn

PS：最近没有登录博客，很多朋友的留言没有看见，这里道歉！还有就是本人较少上QQ，可以邮件交流。


ceilometer报警器状态评估方式之单一报警器状态评估的具体实现

这篇博客将会解析单一报警器状态评估的具体实现，即/ceilometer/alarm/evaluator/threshold.py中类ThresholdEvaluator所实现的内容。在这个类所实现的若干方法中，所有方法都被方法evaluate所调用，最终实现单一报警器状态的评估操作，我们来看看这个类所有重要方法的实现。


1 def _statistics(self,alarm,query)

  1. def _statistics(self,query):
  2.     """
  3.     获取query和meter_name（meter_name=alarm.rule['meter_name']）指定的监控统计数据列表；   
  4.     client_class是Client（ceilometerclient/v2/client.py），从Client的属性可以看出statistics是StatisticsManager（ceilometerclient/v2/statistics.py），它的list函数被调用，传入的参数是alarm的meter_name（在alarm的属性中可以看到），查询条件query，以及alarm的period；
  5.     最终的返回结果为根据query和period制定的查询条件查询meter_name指定的metrics的结果；
  6.         
  7.     通过客户端通过HTTP协议GET方法获取符合查询条件的statistics列表；
  8.     最终的返回结果为meter_name指定的metrics的结果statistics列表；
  9.     """
  10.     LOG.debug(_('stats query %s') % query)
  11.     try:
  12.         return self._client.statistics.list(
  13.             meter_name=alarm.rule['meter_name'],q=query,period=alarm.rule['period'])
  14.     except Exception:
  15.         LOG.exception(_('alarm stats retrieval Failed'))
  16.         return []
方法小结：

通过客户端通过HTTP协议GET方法获取符合查询条件的statistics列表；
最终的返回结果为meter_name指定的metrics的结果statistics列表；


2 def _sufficient(self,statistics)

  1. def _sufficient(self,statistics):
  2.     """
  3.     确保报警器评估具有足够的数据（仲裁人数）；
  4.     1.根据统计数据的数目来判断是否有足够的数据用于报警器的评估(最小值要大于1)；
  5.     2.如果sufficient为0说明用于仲裁的数目不够，则需要刷新报警器的状态为'insufficient data'；
  6.     """
  7.         
  8.     """
  9.     根据统计数据的数目来判断是否有足够的数据用于报警器的评估(最小值要大于1)；
  10.     """
  11.     sufficient = len(statistics) >= self.quorum
  12.         
  13.     """
  14.     如果sufficient为0说明用于仲裁的数目不够，则需要刷新报警器的状态为'insufficient data'；
  15.     """
  16.     if not sufficient and alarm.state != evaluator.UNKNOWN:
  17.         reason = _('%d datapoints are unknown') % alarm.rule[
  18.             'evaluation_periods']
  19.         reason_data = self._reason_data('unknown',alarm.rule['evaluation_periods'],None)
  20.         self._refresh(alarm,evaluator.UNKNOWN,reason,reason_data)
  21.     return sufficient
方法小结：

确保报警器评估具有足够的数据（仲裁人数）；
1.根据统计数据的数目来判断是否有足够的数据用于报警器的评估(最小值要大于1)；
2.如果sufficient为0说明用于仲裁的数目不够，则需要刷新报警器的状态为'insufficient data'；


3 def _transition(self,statistics,compared)

  1. def _transition(self,compared):
  2.     """
  3.     根据statistics是否满足触发报警器条件，来更新报警器报警状态（alarm或ok）；
  4.     1.验证所有的statistics是否满足触发报警器的条件；
  5.       * 所有的statistics均满足触发报警器条件；
  6.       * 所有的statistics均不满足触发报警器条件；
  7.       * 报警器的数据状态为'insufficient data'(数据不充足)；
  8.     2.如果所有的statistics均满足报警条件，则说明需触发报警，报警器的状态设置为'alarm'；
  9.     3.如果所有的statistics均不满足报警条天，则说明报警器处于正常状态，报警器的状态设置为'ok'；
  10.     4.如果当前报警器的状态为'insufficient data'(数据不充足)，则根据最后一个statistics，来判断报警器的发展状态的趋势，进而确定报警器的报警状态；
  11.       * 如果最后一个statistics符合触发报警器的条件，则说明报警器有转换为ALARM状态的趋势，则设置报警器的报警状态为alarm；
  12.       * 如果最后一个statistics不符合触发报警器的条件，则说明报警器有转换为OK状态的趋势，则设置报警器的报警状态为ok；
  13.     """
  14.         
  15.     """
  16.     如果distilled为true，说明所有的statistics均满足触发报警器条件；
  17.     """
  18.     distilled = all(compared)
  19.     
  20.  
  21.     """
  22.     如果unequivocal为true，说明所有的statistics均满足或均不满足触发报警器条件；
  23.     """
  24.     unequivocal = distilled or not any(compared)
  25.     """
  26.     验证报警器的状态是否为'insufficient data'(数据不充足)；
  27.     """
  28.     unknown = alarm.state == evaluator.UNKNOWN
  29.     # repeat_actions：表示每个评估周期都要重新触发的actions；
  30.     continuous = alarm.repeat_actions
  31.  
  32.     """
  33.     如果所有的statistics均满足报警条件，则说明需触发报警，报警器的状态设置为'alarm'；
  34.     如果所有的statistics均不满足报警条天，则说明报警器处于正常状态，报警器的状态设置为'ok'；
  35.     """
  36.     if unequivocal:
  37.         """
  38.         如果所有的statistics均满足报警条件，则说明需触发报警，报警器的状态设置为'alarm'；
  39.         如果所有的statistics均不满足报警条天，则说明报警器处于正常状态，报警器的状态设置为'ok'；
  40.         """
  41.         state = evaluator.ALARM if distilled else evaluator.OK
  42.         reason,reason_data = self._reason(alarm,distilled,state)
  43.             
  44.         """
  45.         如果报警器的状态和要赋予的状态不同，或者continuous为true，则需要刷新报警器的状态为指定状态；
  46.         """
  47.         if alarm.state != state or continuous:
  48.             self._refresh(alarm,state,reason_data)
  49.         
  50.     """
  51.     如果当前报警器的状态为'insufficient data'，则进一步根据最后一个statistics，来判断报警器的发展状态的趋势；
  52.     """
  53.     elif unknown or continuous:
  54.         """
  55.         如果当前状态为UNKNOWN，则根据趋势改变状态，即观察最后一个statistics，
  56.         如果它为true，说明最后一个statistics符合触发报警器的条件，则说明报警器有转换为ALARM状态的趋势，
  57.         如果它为false，说明最后一个statistics不符合触发报警器的条件，则说明报警器有转换为OK状态的趋势；
  58.         """
  59.         trending_state = evaluator.ALARM if compared[-1] else evaluator.OK
  60.             
  61.         """
  62.         如果当前报警器的状态为'insufficient data'，则采用trending_state作为报警器的状态；
  63.         """
  64.         state = trending_state if unknown else alarm.state
  65.         reason,state)
  66.         """
  67.         实现刷新报警器的状态为指定状态；
  68.         """
  69.         self._refresh(alarm,reason_data)
方法小结：

根据statistics是否满足触发报警器条件，来更新报警器报警状态（alarm或ok）；
1.验证所有的statistics是否满足触发报警器的条件；
* 所有的statistics均满足触发报警器条件；
* 所有的statistics均不满足触发报警器条件；
* 报警器的数据状态为'insufficient data'(数据不充足)；
2.如果所有的statistics均满足报警条件，则说明需触发报警，报警器的状态设置为'alarm'；
3.如果所有的statistics均不满足报警条天，则说明报警器处于正常状态，报警器的状态设置为'ok'；
4.如果当前报警器的状态为'insufficient data'(数据不充足)，则根据最后一个statistics，来判断报警器的发展状态的趋势，进而确定报警器的报警状态；
* 如果最后一个statistics符合触发报警器的条件，则说明报警器有转换为ALARM状态的趋势，则设置报警器的报警状态为alarm；
* 如果最后一个statistics不符合触发报警器的条件，则说明报警器有转换为OK状态的趋势，则设置报警器的报警状态为ok；


4 def evaluate(self,alarm)

这个方法最终实现单一报警器状态的评估操作，上面的方法实际上都被这个方法所调用，为单一报警器的评估实现了若干操作（具体实现可以见代码注释）；

  1. def evaluate(self,alarm):
  2.     """
  3.     根据报警器获取指定的metrics的结果statistics列表；
  4.     根据statistics是否满足触发报警器条件，来更新报警器的状态；
  5.     """
  6.     if not self.within_time_constraint(alarm):
  7.         LOG.debug(_('Attempted to evaluate alarm %s,but it is not '
  8.                     'within its time constraint.') % alarm.alarm_id)
  9.         return
  10.  
  11.     # 参照alarm的属性，alarm.rule['query']是
  12.     # Metadata.user_Metadata.server_group == WebServerGroup；
  13.     # 该方法计算evaluate操作的时间段；
  14.     # 在query的内容中添加时间段为[start,now]的条件，
  15.     # 最后返回更改后的query；
  16.     query = self._bound_duration(
  17.             alarm,alarm.rule['query']
  18.     )
  19.  
  20.     """
  21.     _statistics：获取query和meter_name（meter_name=alarm.rule['meter_name']）指定的监控统计数据列表；
  22.     通过客户端通过HTTP协议GET方法获取符合查询条件的statistics列表；
  23.     最终的返回结果为meter_name指定的metrics的结果statistics列表；
  24.     对获取的监控数据列表进行数据的除错处理；
  25.     """
  26.     statistics = self._sanitize(
  27.             alarm,self._statistics(alarm,query)
  28.     )
  29.  
  30.     # _sufficient：确保报警器评估具有足够的仲裁数据（根据statistics数目）；
  31.     # _sufficient方法用来判断返回的查询结果statistics是否够支持evaluate，其中的quorum为statistics的最小长度，默认为1：
  32.           
  33.     """
  34.     确保报警器评估具有足够的数据（仲裁人数）；
  35.     根据statistics是否满足触发报警器条件，来更新报警器的报警状态（alarm或ok）；
  36.     """
  37.     if self._sufficient(alarm,statistics):
  38.         def _compare(stat):
  39.             op = COMPARATORS[alarm.rule['comparison_operator']]
  40.             value = getattr(stat,alarm.rule['statistic'])  
  41.             """
  42.             获取规定的触发报警器的数值限制；
  43.             """
  44.             limit = alarm.rule['threshold']
  45.             LOG.debug(_('comparing value %(value)s against threshold'
  46.                         ' %(limit)s') %
  47.                       {'value': value,'limit': limit})
  48.             return op(value,limit)
  49.  
  50.         """
  51.         根据statistics是否满足触发报警器条件，来更新报警器的报警状态（alarm或ok）；
  52.         """
  53.         self._transition(alarm,map(_compare,statistics))

猜你在找的设计模式相关文章

适配器模式-让不兼容的接口得以适配
适配器模式将一个类的接口转换成客户期望的另一个接口，使得原本接口不兼容的类可以相互合...
策略模式-定义一个算法族
策略模式定义了一系列算法族，并封装在类中，它们之间可以互相替换，此模式让算法的变化独...
设计模式之高质量代码
设计模式讲的是如何编写可扩展、可维护、可读的高质量代码，它是针对软件开发中经常遇到的...
模板方法模式-封装一套算法流程
模板方法模式在一个方法中定义一个算法的骨架，而将一些步骤延迟到子类中，使得子类可以在...
迭代器模式-统一集合的遍历方式
迭代器模式提供了一种方法，用于遍历集合对象中的元素，而又不暴露其内部的细节。
单例模式的五种实现方式及优缺点
单例模式（Singleton Design Pattern）保证一个类只能有一个实例，并提供一个全局访问点。
组合模式-统一的处理个别对象与组合对象
组合模式可以将对象组合成树形结构来表示“整体-部分”的层次结构，使得客户可以用一致的方...
装饰者模式-动态的包装原有对象的行为
装饰者模式能够更灵活的，动态的给对象添加其它功能，而不需要修改任何现有的底层代码。
观察者模式-将消息通知给观察者
观察者模式（Observer Design Pattern）定义了对象之间的一对多依赖，当对象状态改变的时候...
代理模式-访问对象的代理而非其本身
代理模式为对象提供一个代理，来控制对该对象的访问。代理模式在不改变原始类代码的情况下...
算法设计模式多媒体技术正则表达式ElasticsearchFlinkHadoopIDE
受约束摘*day25Java常用类库置信lamda留存持续录入年后正则表达式303.17regularexpre匹多模适20130322基础理论pathmunge涵义reectok需要转义的特资源分享validationex简明魔法里弄形如源码实现完备actionscript