Kafka Center for Tornado Async Applications.

kiel的Python项目详细描述


Python Package VersionDocumentation StatusBuild StatusCode ClimateCodecov.io

kiel是一个纯pythonKafka客户端库,用于Tornado 应用。

安装

PIP

kiel可以通过PyPI获得,安装非常简单:

pip install kiel

手动

若要手动安装,请首先克隆此here repo并:

cd kiel
python setup.py install

文件

可以在Read The Docs上找到更详细的信息。

快速消费示例

fromkielimportclientsfromtornadoimportgen,ioloop@gen.coroutinedefconsume():c=clients.SingleConsumer(brokers=["localhost"])yieldc.connect()whileTrue:msgs=yieldc.consume("examples.colors")formsginmsgs:print(msg["color"])defrun():loop=ioloop.IOloop.instance()loop.add_callback(consume)try:loop.start()exceptKeyboardInterrupt:loop.stop()

发展

代码托管在GitHub

要提交错误或可能的增强,请参见Issue Tracker,也可以找到 在Github上。

许可证

(c)2015-2016威廉格拉斯

kiel根据apache许可(2.0)的条款获得许可。见LICENSE 文件以获取更多详细信息。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
Java流收集组合器   文件如何在java中逐个压缩选定的多个文件夹   从Google存储下载数据时发生java SocketTimeoutException   java在安卓应用程序客户端上从python服务器接收值,然后显示与该值对应的mysql数据   数组如何在Java中测试字符串索引是否为Null   java将一串值拆分并放入一个表中   java Spring Memcached注释不缓存   调用pom中设置的环境变量时出现java问题。xml surefire插件   java修复JFrame中重叠的鼠标侦听器   格式化java。sql。日期至yyyyMMdd   java声音剪辑。如果剪辑不正确,isActive应返回true。启动被调用   无根计算机上hadoop中的java格式化namenode   从字符串数组中删除重复项,而无需在Java中进行显式比较   java Eclipse插件安装错误   java webdriver无法在firefox中单击超链接   动画错误。朗。反思。调用目标异常   java试图调用虚拟方法“void”。小装置。编辑文本。在空对象引用上添加TextChangedListener(安卓.text.TextWatcher)”