Apache NiFi之MySQL數據同步到本地文件系統

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

在Processor中搜索PutFile

 

b).配置PutFile

1.配置Directory: 文件保存路徑
2.可配置Create Missing Directories: 默認true

 

3).啟動服務

可以點擊選擇單個Processor啟動，也可以在空白處點擊流程啟動

 

4).驗證結果

a).MySQL源數據查詢

b).文件內容查詢