Haigha.

Biblioteca de clientes AMQP acionada por eventos
Baixe Agora

Haigha. Classificação e resumo

Propaganda

  • Rating:
  • Licença:
  • BSD License
  • Nome do editor:
  • Vitaly Babiy and Aaron Westendorf
  • Site do editor:
  • http://agoragames.com

Haigha. Tag


Haigha. Descrição

Biblioteca de clientes AMQP conduzida por evento Haigha é uma biblioteca Python que fornece uma biblioteca de clientes simples para interagir com corretores AMQP. Atualmente suporta o protocolo 0.9.1 e é testado na integração contra o mais recente RabbitMQ 2.4.1. Haigha é descendente de py-amqplib e deve muito a seus desenvolvedores. Os objetivos de Haigha são desempenho, simplicidade e adesão à forma e função do protocolo AMQP. Ele adiciona alguns recursos úteis, como a classe de canal e canal.publish_synchronous, para facilitar o uso de recursos poderosos nas aplicações do mundo real. Por padrão, o Haigha opera em um modo completamente assíncrono, confiando em rendimentos para notificar o código de correspondência de respostas o corretor. Quando aplicável, o queda é padronizado para verdade. O código do aplicativo é convidado a chamar uma série de métodos, e Haigha gerenciará a pilha e os handshakes síncronos no loop de eventos. Este é um lançamento de pré-visualização, sem cobertura e documentação de teste de unidade completa, e possivelmente incluindo algumas erratas. É no uso em produção, e processos de dezenas de GBS por dia do tráfego.InstallationPip Install Requirement.txtexamplese O diretório de scripts para vários exemplos, em particular o script de estresse_test que você pode usar para testar o desempenho de Haigha no seu corretor. Abaixo está um exemplo simples de um cliente que conecta, processa uma mensagem e acesa.from haigha.connection Importar ConnectionFrom Haigha.Message Importar MessageImport EventConnection = Conexão (User = 'Guest', Senha = 'Guest', VHost = '/', host = 'localhost', heartbeat = Nenhum, debug = true) def Consumidor (MSG): Imprimir Msg Connection.Close () event.timeout (2, event.abort) ch = conexão.cannel () 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_key') ch.basic.consume 'test_queue', consumidor) ch.basic.publish ('' Body ', Application_Headers = {' Olá ':' World '}),' test_exchange ',' test_key ') event.dispatch () Requisitos: · Pitão


Haigha. Software Relacionado

Sobre nós