Calculer Girl
  1. Calculer Girl
  3. Script de travail python RabbitMQ utilisant 100% du processeur
Intereting Posts
Quel serait le moyen le plus simple de traiter un fichier texte en utilisant JSP? Comment redirect la sortie vers deux fichiers différents lorsque deux commandes sont impliquées simultanément? Mercurial: Comment trouver la révision la plus récente incluant un fichier spécifique, si possible? Comment gérer la redirection des requêtes à partir de l’équilibreur de charge et d’Apache? Comment faire pour lancer une application Rails avec Puma et Capistrano au démarrage Comment puis-je créer une fonction de veille dans l’assemblage MASM 16 bits x86? La limite de fichier ouvert du superviseur ne changera pas lors de l’utilisation de Chef Quelle est la méthode standard pour gérer les installations Python 32 bits et 64 bits côte à côte sur une machine Windows? Unix à Windows: alternative à vsnprintf pour déterminer la longueur? pourquoi la même taille de code produit un fichier exe de taille différente Le fichier se résout en un chemin trop long. La longueur maximale est de 260 caractères le serveur webrtc trun ne fonctionne pas (les glaçons ne fonctionnent pas dans Mozilla Firefox) Comment configurer tomcat pour utiliser différents ports pour différents points de terminaison dans une seule application? erreur bash fork (ressource temporairement indisponible) ne s’arrête pas et continue à apparaître à chaque fois que j’essaie de tuer / redémarrer Comment dois-je procéder à la mise à niveau vers TLS 1.2?

Script de travail python RabbitMQ utilisant 100% du processeur

J’ai porté ce script python qui fait office de serveur RPC en modifiant l’exemple RPC par défaut dans le tutoriel RabbitMQ trouvé ici . Cela fonctionne bien dans mon ordinateur portable. Mais quand je l’exécute dans un amazon ec2 High CPU Medium Instance avec ces spécifications:

1,7 Gio de mémoire

5 unités de calcul EC2 (2 cœurs virtuels avec 2,5 unités de calcul EC2 chacune)

350 Go de stockage d’instance

Il prend 100% de CPU. Bien que mon ordinateur portable avec presque la même configuration fonctionne avec moins de 4% d’utilisation du processeur.

Voici mon code 

#!/usr/bin/env python import pika import commands import socket import base64 connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.queue_declare(queue='rpc_queue') def on_request(ch, method, props, body): #print body body = base64.b64decode(body) print body run = commands.getoutput(body) response = socket.gethostname() print response ch.basic_publish(exchange='', routing_key=props.reply_to, properties=pika.BasicProperties(correlation_id = \ props.correlation_id), body=str(response)) ch.basic_ack(delivery_tag = method.delivery_tag) channel.basic_qos(prefetch_count=1) channel.basic_consume(on_request, queue='rpc_queue') print " [x] Awaiting RPC requests" channel.start_consuming()

Comment puis-je réparer cela ?

Finalement trouvé le problème. C’était un bug dans Pika, j’ai eu cette information de la liste de diffusion de rabbitmq. J’avais installé le pika à travers le pypi. pip install pika .

Pour résoudre ce problème, j’ai désinstallé pika

pip uninstall pika

et réinstallé de git

pip install git+https://github.com/pika/pika.git .

Et cela l’a résolu.