NIFI从mysql导入Hbase(还没弄完)

 

 

 

端口是自定义的

http://desktop:9091/nifi/

 

 

此时没配置完，有页面会提示invalid.

然后点击右边的箭头得到下面的图：

 

然后点击齿轮,填写表格如下:

Database Connection URL	jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=true
Database Driver Class Name	com.mysql.jdbc.Driver
Database Driver Location(s)	/home/appleyuchi/bigdata/apache-hive-3.0.0-bin/lib/./mysql-connector-java-8.0.20.jar
Database User	appleyuchi
Password	appleyuchi

填写完后点击闪电符号生效

 

 

回到ExecuteSQL的properties，设置SQL select query为想要查询的SQL语句，设置Max Wait Time为10 seconds。

 

从ExecuteSQL里出来的是avro格式的数据，要先将其转化成json格式，再导入HBase。拖一个ConvertAvroToJson Processor到界面。然后，从ExecuteSQL连一条线到ConvertAvroToJson，关系为success。

 

 

Reference:

https://www.jianshu.com/p/0ff537f93450