Hauma Biblioteca de clientes AMQP accionada por eventos
Descargar ahora

Hauma Clasificación y resumen

Hauma Etiquetas

cliente Biblioteca de Python Pitón Amqp Cliente de amqp

Hauma Descripción

Biblioteca de clientes AMQP accionada por eventos HaGHAGA es una biblioteca de Python que proporciona una biblioteca de clientes fácil de usar para interactuar con los corredores AMQP. Actualmente admite el protocolo 0.9.1 y está probado la integración frente al último RabbitMQ 2.4.1. HaIGA es un descendiente de PY-AMQPLIB y debe mucho a sus desarrolladores. Los objetivos de Hauma son el rendimiento, la simplicidad y la adherencia a la forma y la función del protocolo AMQP. Agrega algunas características útiles, como la clase de canalpool y el canal.publish_synchronous, para facilitar el uso de características poderosas en aplicaciones del mundo real. Por defecto, Haigha funciona en un modo completamente asíncrono, confiando en devoluciones de llamada para notificar el código de respuestas de la aplicación de El corredor. Donde corresponda, NOWAIT se prenda por defecto a VERDADERO. El código de la aplicación es bienvenido a llamar a una serie de métodos, y HaGHA administrará los apretones de manos de la pila y síncrona en el bucle de eventos. Esta es una versión de vista previa, que carece de cobertura y documentación de prueba de unidad completa, y posiblemente incluyendo algunos erratas. Sin embargo, se encuentra en la producción, y los procesos docena de GBS por día de tráfico.InstallationPIP INSTALACIONES -R REQUISITOS.TXTEXAMPEEEE El directorio de scripts para varios ejemplos, en particular el script STORS_TEST que puede usar para probar el rendimiento de Haigha contra su corredor. A continuación se muestra un ejemplo simple de un cliente que conecta, procesa un mensaje y se deja atrás. FROM HeGHA.CONENEPTORIR INCLECCIÓN DE IMPORTE DE IMPORTE FORMAYA.MESSAY IMPORT MARSEAMIMPORT EVENTCONENECTORION = CONEXIÓN (USER = 'Guest', Password = 'Guest', Vhost = '/', Host = 'localhost', HeartBeat = Ninguno, depuración = verdadero) Def Consumer (MSG): Imprimir Msg Connection.CerLose () Event.TimeOut (2, Event.Abort) CH = Connection.channel () CH.EXCHANGE.DECLARE ( 'test_exchange', 'direct', auto_delete = true) ch.queue.declare ('test_queue', auto_delete = true) ch.queue.bind ('test_queue', 'test_exchange', 'test_ey') CH.BASIC.Consume ( 'test_queue', consumidor) ch.basic.publish (Mensaje ("Body ', Application_Headers = {' Hello ':' World '}),' test_exchange ',' test_exchange ') evento.dispatch () Requisitos: · Python

Hauma Software relacionado