<div dir="ltr"><div dir="ltr"><br></div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">Le ven. 15 nov. 2019 à 10:17, Blom, Merlin, NMU-OI <<a href="mailto:merlin.blom@bertelsmann.de">merlin.blom@bertelsmann.de</a>> a écrit :<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div lang="DE"><div class="gmail-m_-2242700175155264572WordSection1"><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">Hey there,<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">it seems to me as if <a href="http://ask.openstack.org" target="_blank">ask.openstack.org</a> is down, so I ask my question here:<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">I’d like to listen to oslo messages from cinder as I do for neutron and octavia to know what is going on.<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">For me the following code worked for neutron:<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">EXCHANGE_NAME = os.getenv('EXCHANGE_NAME', 'neutron')<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">ROUTING_KEY = os.getenv('ROUTING_KEY', '<a href="http://notifications.info" target="_blank">notifications.info</a>')<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif">QUEUE_NAME = os.getenv('QUEUE_NAME', 'messaging_queue')<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">BROKER_URI = os.getenv('BROKER_URI', 'UNDEFINED')<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="NL">BROKER_PASSWORD = os.getenv('BROKER_PASSWORD', '')<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="NL"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">class Messages(ConsumerMixin):<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">    def __init__(self, connection):<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        self.connection = connection<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        return<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">def get_consumers(self, consumer, channel):<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        exchange = Exchange(EXCHANGE_NAME, type="topic", durable=False)<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        queue = Queue(QUEUE_NAME, exchange, routing_key=ROUTING_KEY, durable=False, auto_delete=True, no_ack=True)<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        return [consumer(queues=[queue], callbacks=[self.on_message])]<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">    def on_message(self, body, message):<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        try:<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">            print(message)<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        except Exception as e:<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">            <a href="http://log.info" target="_blank">log.info</a>(repr(e))<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">if __name__ == "__main__":<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">    <a href="http://log.info" target="_blank">log.info</a>("Connecting to broker {}".format(BROKER_URI))<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">    with BrokerConnection(hostname=BROKER_URI, userid='messaging', password=BROKER_PASSWORD,<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">                          virtual_host='/'+EXCHANGE_NAME,<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">                          heartbeat=4, failover_strategy='round-robin') as connection:<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        Messaging(connection).run()<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">        BrokerConnection.connection.close()<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">But on the cinder vhost (/cinder)</span></p></div></div></blockquote><div> </div>Are you sure cinder use a dedicated vhost? I'm notconviced, if I'm right they all use the default vhost '/'.<div><br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div lang="DE"><div class="gmail-m_-2242700175155264572WordSection1"><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">I can’t find an exchange that the code is working on. (cinder, cinder-backup, …)<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">I tried using the rabbitmq tracer: <a href="https://www.rabbitmq.com/firehose.html" target="_blank"><span style="color:windowtext;text-decoration:none">https://www.rabbitmq.com/firehose.html</span></a><u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">And got all the cinder messages but I don’t want to use it in production because of performance issues.<u></u><u></u></span></p><p class="MsoNormal"><span lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">Does anyone have an idea how to find the correct exchange for the notification info queue in cinder?<u></u><u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US"><u></u> <u></u></span></p><p class="MsoNormal"><span style="font-size:10pt;font-family:"Arial",sans-serif" lang="EN-US">Cheers,<u></u><u></u></span></p><p class="MsoNormal" style="text-align:justify;line-height:120%"><span style="font-size:10pt;line-height:120%;font-family:"Arial",sans-serif;color:black;letter-spacing:0.05pt" lang="EN-US">Merlin<u></u><u></u></span></p></div></div></blockquote></div><br clear="all"><br>-- <br><div dir="ltr" class="gmail_signature"><div dir="ltr"><div><div dir="ltr"><div><div dir="ltr"><div><div dir="ltr"><div><div dir="ltr"><div><div dir="ltr"><div>Hervé Beraud</div><div>Senior Software Engineer<br></div><div>Red Hat - Openstack Oslo</div><div>irc: hberaud</div><div>-----BEGIN PGP SIGNATURE-----<br><br>wsFcBAABCAAQBQJb4AwCCRAHwXRBNkGNegAALSkQAHrotwCiL3VMwDR0vcja10Q+<br>Kf31yCutl5bAlS7tOKpPQ9XN4oC0ZSThyNNFVrg8ail0SczHXsC4rOrsPblgGRN+<br>RQLoCm2eO1AkB0ubCYLaq0XqSaO+Uk81QxAPkyPCEGT6SRxXr2lhADK0T86kBnMP<br>F8RvGolu3EFjlqCVgeOZaR51PqwUlEhZXZuuNKrWZXg/oRiY4811GmnvzmUhgK5G<br>5+f8mUg74hfjDbR2VhjTeaLKp0PhskjOIKY3vqHXofLuaqFDD+WrAy/NgDGvN22g<br>glGfj472T3xyHnUzM8ILgAGSghfzZF5Skj2qEeci9cB6K3Hm3osj+PbvfsXE/7Kw<br>m/xtm+FjnaywZEv54uCmVIzQsRIm1qJscu20Qw6Q0UiPpDFqD7O6tWSRKdX11UTZ<br>hwVQTMh9AKQDBEh2W9nnFi9kzSSNu4OQ1dRMcYHWfd9BEkccezxHwUM4Xyov5Fe0<br>qnbfzTB1tYkjU78loMWFaLa00ftSxP/DtQ//iYVyfVNfcCwfDszXLOqlkvGmY1/Y<br>F1ON0ONekDZkGJsDoS6QdiUSn8RZ2mHArGEWMV00EV5DCIbCXRvywXV43ckx8Z+3<br>B8qUJhBqJ8RS2F+vTs3DTaXqcktgJ4UkhYC2c1gImcPRyGrK9VY0sCT+1iA+wp/O<br>v6rDpkeNksZ9fFSyoY2o<br>=ECSj<br>-----END PGP SIGNATURE-----<br><br></div></div></div></div></div></div></div></div></div></div></div></div></div></div>