假设Windows系统中有一个目录“C:\mylogs”,这个目录下不断有新的文件生成,使用Flume采集这个目录下的文件,并把文件内容显示到控制台(屏幕)。 在Flume安装目录的conf子目录下,新建一个名称为example1.conf的配置文件,该文件的内容如下,补充完整配置文件的内容。 #定义三大组件名称 A1.sources = r1 A1.channels = c1 A1.sinks = k1 #定义Source A1.sources.r1.type = spooldir A1.sources.r1.spoolDir = C:/mylogs/ #定义Channel A1.channels.c1.type = memory A1.channels.c1.capacity = 10000 A1.channels.c1.transactionCapacity = 100 #定义Sink A1.sinks.k1.type = #组装Source、Channel、Sink A1.sources.r1.channels = c1 A1.sinks.k1.channel = c1
把JSON格式数据放入Kafka发送出去,编写一个生产者程序producer_json.py:
编写一个生产者程序producer_test.py用来生成消息:
通过urllib.request模块实现发送GET请求获取百度网页内容的实例
通过urllib3模块实现GET请求获取百度网页内容的实例:
使用Python操作mysql数据库,获取数据库的版本。
编写代码绘制一个散点图,展示学生的数学和英语成绩。假设有以下数据。 math____scores = [80, 85, 90, 70, 75] english____scores = [75, 90, 85, 80, 95]