如何向 Kylo 添加数据库源
How to add a database source to Kylo
我想在 Kylo 中创建一个新的数据摄取类型提要,以将数据从外部数据库导入到 Hive 中。在提要向导的第二步,有一个用于源数据库连接的下拉列表,但未列出我的数据库。如何将我的数据库添加到此列表?
Kylo 通过查找 DBCPConnectionPool 类型的控制器服务从 Apache NiFi 检索数据库连接列表。它使用控制器服务的数据库连接 URL、数据库驱动程序 Class 名称和数据库用户属性来创建自己的数据库连接。密码来自 Kylo 的 application.properties 文件。
以下是将新数据库添加到 Kylo 中的源数据库连接列表的方法:
- 在 Apache NiFi 的根进程组下配置一个新的控制器服务以连接到您的数据库。
- 将数据库的 JDBC 驱动程序 jar 文件复制到 Kylo 的插件文件夹。这通常位于 /opt/kylo/kylo-services/plugin/.
- 将数据库密码添加到 Kylo 的 application.properties 文件中。这通常在 /opt/kylo/kylo-services/conf/ 中。
- 属性 的名称应遵循以下格式:
nifi.service.<controller-service-name>.password
- 其中
<controller-service-name>
是控制器服务的名称,全部小写,空格替换为下划线。
- 例如,来自 Kylo 沙箱的 MySQL 控制器服务的 属性 是:
nifi.service.mysql.password
- 重新启动 kylo-services 服务,新的源数据库连接应该可用:
service kylo-services restart
我想在 Kylo 中创建一个新的数据摄取类型提要,以将数据从外部数据库导入到 Hive 中。在提要向导的第二步,有一个用于源数据库连接的下拉列表,但未列出我的数据库。如何将我的数据库添加到此列表?
Kylo 通过查找 DBCPConnectionPool 类型的控制器服务从 Apache NiFi 检索数据库连接列表。它使用控制器服务的数据库连接 URL、数据库驱动程序 Class 名称和数据库用户属性来创建自己的数据库连接。密码来自 Kylo 的 application.properties 文件。
以下是将新数据库添加到 Kylo 中的源数据库连接列表的方法:
- 在 Apache NiFi 的根进程组下配置一个新的控制器服务以连接到您的数据库。
- 将数据库的 JDBC 驱动程序 jar 文件复制到 Kylo 的插件文件夹。这通常位于 /opt/kylo/kylo-services/plugin/.
- 将数据库密码添加到 Kylo 的 application.properties 文件中。这通常在 /opt/kylo/kylo-services/conf/ 中。
- 属性 的名称应遵循以下格式:
nifi.service.<controller-service-name>.password
- 其中
<controller-service-name>
是控制器服务的名称,全部小写,空格替换为下划线。 - 例如,来自 Kylo 沙箱的 MySQL 控制器服务的 属性 是:
nifi.service.mysql.password
- 属性 的名称应遵循以下格式:
- 重新启动 kylo-services 服务,新的源数据库连接应该可用:
service kylo-services restart