bruto le permite producir mensajes al servicio de mensajería de publicación / suscribirse distribuidos en Kafka
Descargar ahora

bruto Clasificación y resumen

bruto Etiquetas

Biblioteca de Python Pitón mensajes

bruto Descripción

Brod es un módulo Python que le permite producir mensajes al servicio de mensajería de publicación / suscribirse distribuidos de Kafka. Comenzó como un tenedor de Pykafka (https://github.com/dsully/pykafka), pero se convirtió en una reescritura total, ya que necesitábamos agregar muchas características. El nombre de Max Brod, Franz Kafka, amigo y partidario de Franz Kafka.InstallationeReasy_Install Brodnote: el El paquete ZC.ZK tiene una dependencia de los enlaces de los encargados del zoológico de Python que no están incluidos durante su instalación. Se pueden instalar con Easy_Install ZC-ZOOKEEPER-estática, consulte la documentación de ZC.ZK para obtener más información http://pypi.python.org/pypi/zc.zk/0.5.usagedending un simple MessageImport brodkafka = brod.kafka (host = 'localhost') KAFKA.PRODUCE ("TESTO TEMA", "HELLO MUNDO") Enviando una secuencia de MensajesImport brodkafka = brod.kafka (host = 'localhosthost') kafka.produce ("test-topic", ) consumiendo mensajes uno por Oneimport Brodkafka = Brod.kafka (host = 'localhost') para offset, mensaje en brod.fetch ("test-topic", offset = 0): imprimir mensajería de un consumidor basado en Zookeeper. Brod.ZK Import zkconsumerconsumer = zkconsumer ('zk_host: 2181', 'my_consumer_group', 'my_topic_group', 'my_topic', autocommit = true) # urdels foreverfor msg_set en consumer.poll (poll_interval = 1): para offset, msg en msg_set: impresión offset, MSG_SET.BROKER_PARTITION, MSGNONBLOCKING TORNADO CLIENTE SOPORTE SOPORTEIMPORTE TIMEIMPORT TORNADO.IOUTOOPIMPORT TORNADO.WEBDETROM BROD IMPORT MAYOR_OFFSETTROM BROD.NONBLOCKING Importar KafkatornAdoclass MainHandler (Tornado. Web.RequeStHandler): Def Inicialice (Self, Kafka, Tema): self.kafka = kafka self.topic = topic def Post (yo): Data = Self.Get_Argument ('Datos') Self.kafka.produce (self.topic , datos) @ tornado.web.asynchronous Def Get (yo): Brod.offsets (self.topic, Últimas_offset, max_offsets = 2, callback = self._on_offset) DEF _ON_OFFSET (yo, compensaciones): offset = offsets # Obtenga la segunda a la última a la última compensación de Brod.Fetch (self.topic, offset, callback = self._on_fetch) def _on_fetch (self, mensajes): para offset, mensaje en mensajes: self.write ("{0}: {1} ".format (offset, mensaje)) self.finish () kafka = kafkatornado () aplicación = tornado.web.application () Si __Name__ == "__main__": parse_command_line () aplicación.listen (8888) tornado.ioloop.ioloop.Instance (). Iniciar () Página de inicio del producto

bruto Software relacionado