【文件属性】:
文件名称:exotel_task:用Python编程以将数据从Kafka流到关系数据库(MySQL)
文件大小:4KB
文件格式:ZIP
更新时间:2021-03-13 21:30:34
Python
exotel_task
任务名称:将数据从Kafka流传输到关系数据库(MySQL)的程序使用的语言:Python Python使用的库:mysql.connector,kafka-python
#先决条件
Python3.x
卡夫卡
MySQL
#使用的版本
的Python 3.7.9
卡夫卡2.7.0
MySQL 8.0
#要安装python库,请使用以下命令pip install kafka-python pip install MySQL-python
#对于Kafka安装,请访问以下URL,以获取 。
#对于MySQL,请访问以下网址以获取安装步骤
#运行Python脚本之前要执行的命令转到安装Kafka的目录并运行以下命令
#要运行zookeeper-它运行在localhost:2181 ... Kafka>。\ bin \ windows \ zookee
【文件预览】:
exotel_task-main
----python-producer.py(3KB)
----python-consumer.py(3KB)
----README.md(2KB)