zoukankan      html  css  js  c++  java
  • aodh M版本新特性

    之前alarm evaluator service and alarm notifier services之间的通信采用RPC的方式,消耗较大,增加work queue的方式可以获得更好的性能,

    +        if conf.ipc_protocol == 'rpc':
    +            self.ipc = 'rpc'
    +            self.rpc_server = messaging.get_rpc_server(
    +                conf, transport, conf.notifier_rpc_topic, self)
    +        else:
    +            self.ipc = 'queue'
    +            target = oslo_messaging.Target(topic=conf.notifier_topic)
    +            self.listener = messaging.get_notification_listener(
    +                transport, [target],
    +                [AlarmEndpoint(self.notifiers)])

    所谓work queue的方式就是把evaluator 的结果作为消息的payload发送给alarm:

    +        payload = {'actions': actions,
    +                   'alarm_id': alarm.alarm_id,
    +                   'alarm_name': alarm.name,
    +                   'severity': alarm.severity,
    +                   'previous': previous,
    +                   'current': alarm.state,
    +                   'reason': six.text_type(reason),
    +                   'reason_data': reason_data}
    +        self.notifier.sample(self.ctxt, 'alarm.update', payload)

    参考:https://review.openstack.org/#/c/247211/

  • 相关阅读:
    java学习55天2020/8/29
    java学习51天2020/8/25
    java学习55天2020/8/31
    java学习49天2020/8/23
    java学习52天2020/8/26
    java学习48天2020/8/22
    2020.12.05
    2020.12.04
    2020.12.07
    2020.12.03
  • 原文地址:https://www.cnblogs.com/allcloud/p/5404214.html
Copyright © 2011-2022 走看看