برود
التحميل الان

برود الترتيب والملخص

برود العلامات

مكتبة بيثون بيثون رسائل

برود وصف

BROD هي وحدة بيثون تتيح لك إنتاج رسائل إلى خدمة المراسلة / الاشتراك الموزعة في Kafka. بدأت كخمشة من pykafka (https://github.com/dsully/pykafka)، لكنها أصبحت إجمالية واحدة كما كنا بحاجة إلى إضافة العديد من الخصائص. إنها اسم اسمه ماكس برود، صديق فرانز كافكا و supporter.installationeasy_install brodnote: تحتوي حزمة ZC.ZK على تبعية على ارتباط حارس حديقة الحيوان Python غير المدرجة أثناء تثبيتها. يمكن تثبيتها مع Easy_Install ZC-ZOOKEKEBER-STATIC انظر وثائق ZC.ZK لمزيد من المعلومات http://pypi.python.org/pypi/zc.zk/0.5.Asagesencing MessageImport بسيطة برودكافكا = brod.kafka (المضيف = "Localhost "العالم"]) تستهلك الرسائل واحدة بواسطة Oneimport Brodkafka = Brod.Kafka (المضيف = 'Localhost') للإزاحة، رسالة في Brod.Fetch ("Test-Topic"، Offset = 0): طباعة MessageUs Brod.ZK استيراد ZKCONSUMSCONSUMER = ZKCONSUMER ('ZK_HOST: 2181'، 'my_consumer_group'، 'my_topic'، autocommit = true) # استطلاعات استطلاعات الرأي foreverfor. msg_set في المستهلك. MSG_SET.BROKER_PARTITION، MSGNONBLOCKING TORNADO عميل Supportimport Timeimport Tornado.ioloopimport Tornado.webfrom Brod استيراد أحدث_offetfrom Brod.nonblocking استيراد Kafkatornadoclass Mainhandler (Tornado. Web.Requesthandler): تهيئة Def (الذات، Kafka، الموضوع): Self.Kafka = Kafka Self.topic = موضوع Def Post (الذاتي): البيانات = self.get_argument ('البيانات') self.kafka.produce (self. البيانات) @ tornado.web.web.asynronchronous الحصول على (الذاتي) # احصل على الثانية إلى أحدث أوفست brod.fetch (self.topopopic، ownowset، رد الاتصال = self._on_fetch) def _on_fetch (الذات، الرسائل): للحصول على إزاحة، رسالة في الرسائل: self.write ("{0}: {1} ".format (الإزاحة، رسالة)) self.finish () kafka = kafkatornado () التطبيق = tornado.web.application (

برود برامج ذات صلة