brod
Download nu

brod Rangschikking & Samenvatting

brod Tags

Python-bibliotheek Python berichten

brod Beschrijving

Brod is een Python-module waarmee u berichten kunt produceren naar de KAFKA Distributed Publish / Abonneer Messaging Service. Het begon als een vork van Pykafka (https://github.com/dully/pyptafka), maar werd een totaal herschrijving omdat we veel functies moesten toevoegen. Het is vernoemd naar Max Brod, Franz Kafka's vriend en supporter.installationeasy_install Brodnote: The ZC.ZK-pakket heeft een afhankelijkheid van de bindingen van Python Zoo-keeper die niet zijn opgenomen tijdens de installatie. Ze kunnen worden geïnstalleerd met Easy_Install ZC-ZOEOKEER-STATIC, zie de documentatie ZC.ZK voor meer informatie http://pypi.python.org/pypi/zc.zk/0.5.US DIE EEN EENVOUDIGE MESSAGEIMPORT BRORODKAFKA = BROD.KAFKA (HOST. 'localhost') kafka.Producce ("Test-topic", "Hallo World") Een reeks van MessingIMport brodkafka = Brod.kafka (host = 'localhost') sturen Kafka.Producce ("Test-Topic", ) Berichten Eén door OneMport Brodkafka = Brod.kafka (host = 'localhost') voor offset, bericht in Brod.fetch ("Test-topic", offset = 0): Print Messageing A Zookeper-based ConsumerFrom Brod.zk Import ZKConsumerConsumer = ZKConsumer ('ZK_HOST: 2181', 'My_Consumer_group', 'My_Topic', Autocommit = True) # Polls Foreverfor msg_set in consument.poll (Poll_Interval = 1): voor offset, MSG in MSG_SET: afdrukken offset, msg_set.broker_partitie, MSGNONBLOCKING TORNADA Client SupportIMPORT TIMAPPORT TORNADO.IOLOOPIMPORT Tornado.WebFrom Brod Import Nieuwste_offsetFrom Brod.NonBlocking Import KafkatornadoClass MainHandler (Tornado. Web.requestHandler): Def Initialize (Self, Kafka, Topic): Self.kafka = Kafka Self.Topic = Topic Def Post (Self): Data = Self.get_argument ('data') Self.KAFKA.PRODUCE (Self.Topic , Data) @ tornado.web.asynchrone def Get (self): Brod.Offsets (self.Topic, nieuwste_offset, max_offsets = 2, callback = self._on_offset) Def _on_offset (zelf, offsets): offset = offsets # Krijg de tweede naar de nieuwste offset brod.fetch (self.topic, offset, callback = self._on_fetch) Def _on_fetch (self, berichten): voor offset, bericht in berichten: self.write ("{0}: {1} " World '}),]) Als __Name__ == "__MAIN__": PARSE_COMMAND_LINE () Application.Listen (8888) Tornado.IOLOOP.IOLOOP.INSTANTIE (). Start () de startpagina van het product

brod Gerelateerde software