1).配置ExecuteSQLRecord
a).选择ExecuteSQLRecord
在Processor中搜索ExecuteSQLRecord
b).配置ExecuteSQLRecord
1.创建Database Connection Pool
2.创建JsonRecordSetWriter
3.配置SQL select query
select Host,User,authentication_string from mysql.user;
c).创建DBCPConnectionPool
在Database Connection Pool中选择DBCPConnectionPool
d).配置DBCPConnectionPool
1.Database Connection URL: jdbc:mysql://hostname:3306/mysql
2.Database Driver Class Name: com.mysql.jdbc.Driver
3.Database User: username
4.Database Password: password
e).激活服务
f).选择JsonRecordSetWriter
在Processor中搜索JsonRecordSetWriter
g).配置JsonRecordSetWriter
h).选择AvroSchemaRegistry
在Processor中搜索AvroSchemaRegistry
i).配置AvroSchemaRegistry
j).激活JsonRecordSetWriter & AvroSchemaRegistry
2).配置PutFile
a).选择PutFile
b).配置PutFile
1.配置Directory: 文件保存路径
2.可配置Create Missing Directories: 默认true
3).启动服务
可以点击选择单个Processor启动，也可以在空白处点击流程启动
4).验证结果
a).MySQL源数据查询
b).文件内容查询
