将SQL连接到apache nifi

Question

我是nifi的新手,我想将SQL服务器数据库连接到nifi并使用处理器创建数据流.我怎么能这样做,任何人都可以清楚地帮助我.

先谢谢Sam

Answer 1

以下是两篇关于使用NiFi获取和传出数据库信息的精彩文章:

1. http://www.batchiq.com/database-injest-with-nifi.html

2. http://www.batchiq.com/database-extract-with-nifi.html

它们描述/说明如何配置DBCPConnectionPool服务以提供与RDBMS的连接,以及示例流以提取数据和接收数据.

Answer 2

扩展mattyb答案

如果您使用的是最新的Hortonworks沙箱或其他使用泊坞容器的设置,请阅读以下内容.

您必须在docker中安装JDBC jar文件.对于SQL Server,它应该是6.2或更高.

docker ps
docker exec -it <mycontainer uuid> bash

如何进入码头工人容器？ 将帮助您登录容器.

cd file:///usr/lib/jvm/jre/lib/
mkdir jdbc
cd ./jdbc
wget https://download.microsoft.com/download/3/F/7/3F74A9B9-C5F0-43EA-A721-07DA590FD186/sqljdbc_6.2.2.0_enu.tar.gz
tar xvzf sqljdbc_6.2.2.0_enu.tar.gz
cp ./sqljdbc_6.2/enu/mssql-jdbc-6.2.2.jre8.jar ./

jdbc:sqlserver://192.168.1.201:1433; databaseName = [your database] com.microsoft.sqlserver.jdbc.SQLServerDriver

您可以将file:/// usr/lib/jvm/jre/lib /更改为您想要的任何路径.