MRS3.1.1-LTS HetuEngine对接oracle数据源操作方法
MRS3.1.1-LTS HetuEngine对接oracle数据源操作方法
注:MRS3.1.1-LTS HetuEngine 内核版本为openlookeng1.2.0版本,兼容openlookeng社区功能,对接指南可参考社区指导,配置文件可参考社区内容。
Oracle数据源配置 :https://openlookeng.io/zh-cn/docs/docs/connector/oracle.html
操作场景
本章节以Oracle 11g版本为例,讲解如何使用HetuEngine连接Oracle数据源。
前提条件
Oracle数据源已安装,可正常访问。
已在FusionInsight_Hetu集群中创建“人机”用户,请参考产品文档“管理员指南 > 系统设置 > 权限设置 > 用户管理 > 创建用户”章节。
操作步骤
1、 下载HetuEngine连接oracle相关jar包
下载地址:https://openlookeng.io/zh-cn/download.html
下载hetu-server-1.2.0.tar.gz,下载完成后解压至本地PC。
2、 下载oracle JDBC驱动
下载地址:https://www.oracle.com/database/technologies/appdev/jdbc-downloads.html
根据安装的Oracle版本选择对应的jdbc驱动,下载至本地PC。
3、 后台添加oracle jar包及驱动
登录已安装FusionInsight集群客户端的节点,从hdfs目录上下载HetuEngine内核包presto.tar.gz并解压:
hdfs dfs -get /user/hetuserver/8.0.0/package/presto.tar.gz
tar -xf presto.tar.gz
l 上传步骤1下载的hetu-server-1.2.0/plugin目录下的oracle文件夹上传至解压的presto/plugin目录下
l 上传步骤2下载的oracle JDBC驱动至解压的presto/plugin/oracle目录下。
l oracle目录改为700,oracle目录下的文件权限改为600,属组均改为omm:wheel
chmod 700 ./oracle/
chmod 600 ./oracle/*
chown -R omm:wheel ./oracle/
4、 压缩并上传presto.tar.gz至hdfs
(备份原有包:mv presto.tar.gz presto.tar.gz.bak)
tar -czf presto.tar.gz presto
hdfs dfs -put -f presto.tar.gz /user/hetuserver/8.0.0/package/presto.tar.gz
hdfs dfs -chown hetuserver:hadoop /user/hetuserver/8.0.0/package/presto.tar.gz
5、 Scp presto.tar.gz至所有hsbroker节点
此步骤是为避免hsbroker本地包与hdfs上不一致。
(路径根据实际修改,默认安装路径为:/opt/huawei/Bigdata/FusionInsight_Hetu_8.1.1/install/FusionInsight-HetuEngine-1.2.0/hetuserver/presto)
scp presto.tar.gz root@8.5.xx.x:/opt/huawei/Bigdata/FusionInsight_Hetu_8.1.1/install/FusionInsight-HetuEngine-1.2.0/hetuserver/presto
登录所有hsbroker节点执行:
cd /opt/huawei/Bigdata/FusionInsight_Hetu_8.1.1/install/FusionInsight-HetuEngine-1.2.0/hetuserver/presto
rm -rf ./presto
chmod 600 ./presto.tar.gz
chown omm:wheel ./presto.tar.gz
tar -xf ./presto.tar.gz
6、 创建oracle的catalog 配置文件
新建文件oracle.properties文件内容如下(对接多个oracle数据源创建不同名的properties文件即可,如oracle2.properties):
connector.name=oracle
connection-url=jdbc:oracle:thin:@ip:1521:servicename
connection-user=username
connection-password=password
connector.name |
oracle |
connection-url |
ip代表oracle的ip地址, 默认端口1521, 如: connection-url=jdbc:oracle:thin:@100.xxx.xx.xxx:1521: serviceName serviceName:可使用sql plus 登录SYS执行show parameter service_names查询 |
connection-user |
登录oracle的用户名 |
connection-password |
登录oracle的用户密码 |
7、 上传配置文件至hdfs
oracle.properties为步骤6创建的文件
hdfs dfs -mkdir /user/hetuserver/fiber/catalog/oracle
hdfs dfs -put oracle.properties /user/hetuserver/fiber/catalog/oracle/
hdfs dfs -chown -R hetuserver:hadoop /user/hetuserver/fiber/catalog/oracle
8、 在FusionInsight Manager 的Hsconsole web页面重启HetuEngine计算实例
9、进入HetuEngine客户端,测试连接是否成功。
hetu-cli --catalog oracle
show schemas;
- 点赞
- 收藏
- 关注作者
评论(0)