没有项目描述

azure-functions-kafka-binding的Python项目详细描述


kafka的azure函数python绑定

这个项目为用python编写的azure函数提供了kafka绑定,使之更容易 使用来自一个主题的卡夫卡消息。

功能

  • 阅读卡夫卡的主题

入门

通过PYPI安装

pip安装azure函数kafka绑定

通过Git安装

git clone https://github.com/Azure/azure-functions-kafka-extension

cd ./bindings_library/python/

python setup.py install

最低要求

  • python 3.6
  • 有关依赖项,请参见setup.py

用法

fromazure_functions.kafkaimportKafkaEventdefkafkaConsume(kevent:KafkaEvent):print(kevent.get_body().decode('utf-8'))

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

推荐PyPI第三方库


热门话题
java应用程序不是在Eclipse中运行,而是在命令行中运行   swing Java图形组件问题。似乎找不到错误   我需要键盘。close();让代码正常工作?   Springboot中的java HttpSession   抽象语法树我想添加一个语句。我试图解析它,java解析器异常被抛出。如何克服它?   java Hibernate:清理会话   具有不连续子集的java划分问题   java正则表达式查找最后一个冒号后的字符串   java从SpringShell执行OS命令   Java扫描器字符串输入   java字符串索引越界异常(charAt)   java执行器服务终止被卡住   Springockito没有继承java@ContextConfiguration   java如何为一个servlet映射多个url   java安卓获取命令的stderr   java生成类型。表:数据库中的大数字   安卓 Getter Setter返回NothingJava