Brod Hier können Sie Nachrichten an den Kafka-verteilten Publish / Subscribe-Messaging-Service erstellen
Jetzt downloaden

Brod Ranking & Zusammenfassung

Brod Stichworte

Python-Bibliothek Python Mitteilungen

Brod Beschreibung

Brod ist ein Python-Modul, mit dem Sie Meldungen an den Kafka-Distributed Publish / Subscribe Messaging-Service erstellen können. Es begann als Gabel von Pykafka (https://github.com/dsully/pykafka), wurde jedoch insgesamt Umschreiber, da wir viele Funktionen hinzufügen mussten Das ZC.ZK-Paket hat eine Abhängigkeit von Python Zoo-Keeper-Bindungen, die während der Installation nicht enthalten sind. Sie können mit EASY_INSTALL ZC-ZC-ZOOKEEPER-STATIC installiert werden, um weitere Informationen zu erhalten 'localhost') kafka.produce ("test-thebthema", "hello world") Senden einer Sequenz von NachrichtenImport Brodkafka = brod.kafka (Host = 'localhost') kafka.produce ("Testthema", ) Meldungen an der ONEIMPORT BRODKAFKA = BROD.KAFKA (Host = 'localhost') für Offset, Nachricht in Brod.Fetch ("Testthema", Offset = 0): Drucken Sie den Nachrichtendruck mit einem Zookeeper-basierten Consumer-Basis brod.zk import zkconsumerconsumer = zkconsumer ('zk_host: 2181', 'my_topic_group', 'my_topic', autocommit = true) # Umfragen FOREVERFOR MSG_SET in consumer.poll (poll_interval = 1): Für den Offset, MSG in MSG_SET: Druckversatz, msg_set.broker_partition, Msgnonblocking Tornado Client SupportImport TimeImPort Tornado.ioloopImport Tornado.webfrom Brod Import neuartig web.RequestHandler): def Initialize (Selbst, Kafka, Thema): self.kafka = kafka self.topic = thema def post (self): data = self.get_argument ('data') self.kafka.produce (self.topic , daten) @ tornado.web.asynchronous def Get (self): brod.offsets (self.topic, athreat_offset, max_offsets = 2, callback = self._Offsets) def _on_offset (Self, Offsets): Offset = Offsets # Holen Sie sich den zweiten bis den neuesten Offset-BROD.FETCH (self.topic, offset, callback = self._on_fetch) def _on_fetch (Self, Meldungen): Für Offset, Nachricht in Nachrichten: self.write ("{0}: {1} ".Format (Offset, Nachricht)) self.finish () kafka = kafkatornado () Anwendung = tornado.web.Application () Wenn __Name__ == "__main__": parse_command_line () application.listen (8888) tornado.ioloop.ioloop.instance (). Start () Startseite des Produkts

Brod Zugehörige Software