brod Kafka Dağıtılmış Publish / Abone Mesajlaşma Servisi'ne mesajlar üretmenizi sağlar.
Şimdi İndirin

brod Sıralama ve Özet

brod Etiketler

Python Kütüphanesi Python mesajlar

brod Açıklama

Brod, Kafka Dağıtılmış Yayınla / Abone Mesajlaşma Servisi'ne mesajlar üretmenizi sağlayan bir Python modülüdür. Pykafka çatalı (https://github.com/dsully/pykafka) olarak başladı, ancak birçok özellik eklememiz gerektiğinde toplam yeniden yazma oldu. Max Brod, Franz Kafka'nın arkadaşı ve destekçisi. ZC.ZK paketinin, kurulumu sırasında dahil edilmeyen Python Hayvanat Bahçesi Keeper Ciltlerine bir bağımlılığa sahiptir. Easy_install ZC-ZOOKEEKER-Static ile yüklenebilirler. Daha fazla bilgi için zc.zk belgelerine bakın. 'Localhost') Kafka.Produce ("Test Konusu", "Hello World") Bir Mesaj Sırasını Gönderme Brodkafka = Brod.Kafka (Host = '' Localhost ') Kafka.Produce ("Test Konusu", ) mesajı tek angelsport brodkafka = brod.kafka (host = 'localhost') için ofset, brod.fetch ("Test konusu", ofset = 0) için mesajı tüketme brod.zk ithalat zkconsumerconsumer = zkconsumer ('zk_host: 2181', 'my_consumer_group', 'my_topic', autocommit = true) # concorer.poll'da msg_set için Anketler (poll_interval = 1): MSG_Set'te MSG, Yazdırma Ofseti, MSG_SET.BROKER_PARTION, MSGNONBLOCKING Tornado Client SupportImport Timeimport Tornado.ioloopImport Tornado.Webfrom Brod İthalatı Sonrası_offsetfrom brod.Nonblocking ithalat Kafkatornadoclass Mainhandler (Tornado. Web.requestHandler): def başlat (öz, Kafka, konu): self.kafka = Kafka self.topic = Konu def post (öz): Veri = self.get_argument ('veri') self.kafka.produce (self.topic , veriler) @ tornado.web.Asynchronous def olsun (öz): brod.offsets (self.topic, en son_offset, max_offsets = 2, geri arama = self._on_offset) def _on_offset (öz, ofsetler): offset = ofsetler # En son ikinci ofset brod.fetch (self.topic, ofset, geri arama = self._on_fetch) def _on_fetch (öz, mesajlar): ofset, mesajdaki mesaj için: Self.Write ("{0}: {1} ".format (ofset, mesaj)) self.Finish () Kafka = Kafkatornado () Uygulaması = Tornado.Web.Application () Eğer __NAME__ == "__MAIN__": parse_command_line () Application.Listen (8888) tornado.ioloop.ioloop.instance (). Başlat () Ürünün ana sayfası

brod İlgili Yazılım