成都网站app开发,高端制作网站公司,专业网站建设机构,陕西服装网站建设环境#xff1a;浙江移动华为云平台
云平台大数据采用了 Kerberos 认证。
开发历程#xff1a;
1、在宁波大数据实验环境测试通过了JDBC实现从Hive抽取数据导入Oracle功能。
2、通过查看其它项目的数据库访问配置#xff0c;知道了云平台上的oracle配置。
3、获取hive的…环境浙江移动华为云平台
云平台大数据采用了 Kerberos 认证。
开发历程
1、在宁波大数据实验环境测试通过了JDBC实现从Hive抽取数据导入Oracle功能。
2、通过查看其它项目的数据库访问配置知道了云平台上的oracle配置。
3、获取hive的jdbc访问配置。但是无人知道说保密不告知。
但是方法还是有的从访问前source的shell文件里找到了眉目。 [deepenvd26wyjl01 ~]$ cat login.sh
source /app/deepen/jc_client/bigdata_env
export KRB5CCNAME/app/deepen/user_keytab/jc_deepen.cc
kinit -kt /app/deepen/user_keytab/user.keytab jc_deepen
klist [deepenvd26wyjl01 ~]$ beeline
Connecting to jdbc:hive2://ip:24002,ip:24002,ip:24002,ip:24002,ip:24002/;serviceDiscoveryModezooKeeper;zooKeeperNamespacehiveserver2;sasl.qopauth-conf;authKERBEROS;principalhive/hadoop.hadoop.comHADOOP.COM
Debug is true storeKey false useTicketCache true useKeyTab false doNotPrompt false ticketCache is null isInitiator true KeyTab is null refreshKrb5Config is false principal is null tryFirstPass is false useFirstPass is false storePass is false clearPass is false
Acquire TGT from Cache
Principal is jc_deepenHADOOP.COM
Commit Succeeded 0: jdbc:hive2://ip:21066/ 通过辛苦的调配后最后的配置如下 HIVE_Kerberos_URLjdbc:hive2://ip地址:21066/deepen_hive_db;principalhive/hadoop.hadoop.comHADOOP.COMHIVE_Kerberos_krb5_conf/app/deepen/user_keytab/krb5.confHIVE_Kerberos_Userjc_deepenHADOOP.COMHIVE_Kerberos_krb5_Keytab/app/deepen/user_keytab/user.keytabORACLE_DRIVERoracle.jdbc.driver.OracleDriverORACLE_URLxxxxxxORACLE_UserName xxxxORACLE_PassWord xxxx核心代码// 创建连接private Connection getConnnection() throws Exception {/** 使用Hadoop安全登录 **/org.apache.hadoop.conf.Configuration conf new org.apache.hadoop.conf.Configuration();conf.set(hadoop.security.authentication, Kerberos);//System.setProperty(java.security.krb5.conf, /app/deepen/user_keytab/krb5.conf);System.setProperty(java.security.krb5.conf, krb5_conf);try {UserGroupInformation.setConfiguration(conf);//UserGroupInformation.loginUserFromKeytab(hive/hadoop.hadoop.comHADOOP.COM, /app/deepen/user_keytab/user.keytab);UserGroupInformation.loginUserFromKeytab(user, krb5_Keytab);} catch (IOException e1) {e1.printStackTrace();}Class.forName(driverName);Connection conn DriverManager.getConnection(url);System.out.println(#####获取Kerberos-Hive-conn成功---conn.toString());return conn;}
