没有项目描述
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'))