brod. permite produzir mensagens para o serviço de mensagens do Kafka Distributed Publish / Subscribe
Baixe Agora

brod. Classificação e resumo

brod. Tag

Biblioteca Python. Pitão mensagens

brod. Descrição

Brod é um módulo Python que permite produzir mensagens para o serviço de mensagens de publicação / inscrição distribuída Kafka. Começou como um garfo de pykafka (https://github.com/dsully/pykafka), mas tornou-se uma reescrita total como precisávamos adicionar muitos recursos.É nomeado após Max Brod, amigo de Franz Kafka e Supporter.InstallationEasy_install Brodnote: o O pacote zc.zk tem uma dependência das ligações de guardiões do zoológico Python que não estão incluídas durante a instalação. Eles podem ser instalados com Easy_Install ZC-Zookeeper-Static Veja a documentação zc.zk para obter mais informações http://pypi.python.org/pypi/zc.zk/0.5.usagesendando um simples MessageImport Brodkafka = Brod.kafka (host = 'localhost') kafka.produce ("Top-tópico", "Hello World") Enviando uma seqüência de mensagensimport Brodkafka = Brod.kafka (host = 'localhost') kafka.produce ("Top-tópico", ) Consumindo mensagens Um por OneImport Brodkafka = Brod.kafka (host = 'localhost') para offset, mensagem em Brod.fetch ("Top-tópico", offset = 0): Imprimir mensagens de messificação de um consumidor baseado em zookeeper Brod.zk Importar Zkconsumerconsumer = Zkconsumer ('ZK_HOST: 2181', 'my_consumer_group', 'my_topic', autocommit = true) # enquete para semprefor Msg_set no consumer.poll (Poll_interval = 1): para deslocamento, msg no msg_set: imprimir compensação, msg_set.broker_partition, msgnonblocking cliente tornado supportimport timeImport tornado.ioloopimport tornado.webfrom brod importar mais recente_offsetfrom brod.nonblocking importar kafkatornadoclass mainthandler (tornado. web.requesthandler): Def Initialize (auto, kafka, tópico): self.kafka = kafka self.topic = tópico def post (auto): Data = self.get_argument ('Data') self.kafka.produce (self.PoPic , dados) @ Tornado.web.asynchronous def obter (auto): Brod.ffsets (self.topic, mais recente, max_offsets = 2, callback = self._on_offset) def _on_offset (auto, offset = offset = offsets # Obtenha o segundo para o mais recente Offset Brod.fetch (self..pic, deslocamento, callback = self._on_fetch) def _on_fetch (auto, mensagens): para deslocamento, mensagem em mensagens: self.write ("{0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0}: {0} ".Format (compensação, mensagem)) self.finish () kafka = kafkatornado () aplicativo = Tornado.web.application () se __Name__ == "__main__": parse_command_line () aplicativo.Listen (8888) Tornado.ioloop.ioloop.instance (). Início () Homepage do produto

brod. Software Relacionado