专栏首页Hadoop实操Python3环境通过JDBC访问非Kerberos环境的Hive

Python3环境通过JDBC访问非Kerberos环境的Hive

1.文档编写目的

在前面Fayson介绍了在Python2的环境下《如何使用Python Impyla客户端连接Hive和Impala》,本篇文章Fayson主要介绍在Python3的环境下使用Impyla访问非Kerberos环境下的Hive以及将获取到的结果集转换为Pandas的DataFrame。

  • 内容概述

1.前置环境准备及说明

2.Python3示例代码及运行

3.总结

  • 测试环境

1.CM5.14.3和CDH5.14.2

2.Redhat7.4

3.Python 3.6.5

4.集群未启用Kerberos

2.前置环境准备及说明

在使用Impyla访问Hive前,需要安装Python的依赖包,具体需要安装的依赖包列表如下:

six
bit_array
impyla
thrift
thrift_sasl==0.2.0

1.Python3的安装目录/opt/cloudera/anaconda3

2.升级Python的pip版本

[root@cdh02 ~]# /opt/cloudera/anaconda3/bin/pip install --upgrade pip

(可左右滑动)

3.使用Python3的pip安装上述的依赖包

/opt/cloudera/anaconda3/bin/pip install six
/opt/cloudera/anaconda3/bin/pip install bit_array
/opt/cloudera/anaconda3/bin/pip install thrift
/opt/cloudera/anaconda3/bin/pip install thrift_sasl==0.2.0
/opt/cloudera/anaconda3/bin/pip install impyla

(可左右滑动)

3.Python3访问Hive示例代码

from impala.dbapi import connect
from impala.util import as_pandas
conn = connect(host='cdh01.fayson.com',port=10000,database='default',user='hive',auth_mechanism='PLAIN')
print(conn)
cursor = conn.cursor()
cursor.execute('show databases')
results = cursor.fetchall()
print(results)

cursor.execute('select * from ods_user limit 10')
df = as_pandas(cursor)
print(df)

(可左右滑动)

4.示例运行

在服务上使用如下命令运行Python代码

[root@cdh02 python_code]# /opt/cloudera/anaconda3/bin/python impyla_hive.py 

(可左右滑动)

5.总结

1.使用Impyla访问Hive,需要安装impyla及其相应的依赖包(如:six、bit_array、thrift、thrift_sasl)。

2.使用Impyla访问非Kerberos环境下的Hive是,在connect方法中需要添加auth_mechanism和user两个参数,否则会报“No protocol version header”异常。

3.在安装依赖包访问Hive时遇到错误“AttributeError: 'TSocket' object has no attribute'isOpen'”,由于thrift_sasl版本问题,将thrif_salsl版本改为0.2.0即可,详细异常如下:

[root@cdh02 python_code]# /opt/cloudera/anaconda3/bin/python impaly_hive.py
Traceback (most recent call last):
  File "impaly_hive.py", line 2, in <module>
    conn = connect(host='cdh01.fayson.com',port=10000,database='default',user='hive',auth_mechanism='PLAIN')
  File "/opt/cloudera/anaconda3/lib/python3.6/site-packages/impala/dbapi.py", line 147, in connect
    auth_mechanism=auth_mechanism)
  File "/opt/cloudera/anaconda3/lib/python3.6/site-packages/impala/hiveserver2.py", line 758, in connect
    transport.open()
  File "/opt/cloudera/anaconda3/lib/python3.6/site-packages/thrift_sasl/__init__.py", line 67, in open
    if not self._trans.isOpen():
AttributeError: 'TSocket' object has no attribute 'isOpen'

(可左右滑动)

提示:代码块部分可以左右滑动查看噢

为天地立心,为生民立命,为往圣继绝学,为万世开太平。 温馨提示:要看高清无码套图,请使用手机打开并单击图片放大查看。

本文分享自微信公众号 - Hadoop实操(gh_c4c535955d0f)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2018-07-25

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Python3通过JDBC访问非Kerberos环境的Impala

    在前面Fayson介绍了在Python2的环境下《如何使用Python Impyla客户端连接Hive和Impala》及《Python3环境通过JDBC访问非K...

    Fayson
  • 0691-1.4.0-GPU环境下CDSW运行TensorFlow案例

    介绍如何在CDSW中安装集成CUDA9.2版本的tensorflow模块,以及在GPU环境下运行tensorflow案例。代码参考上一篇文章《0690-Tens...

    Fayson
  • 如何在非安全的CDH集群中部署Jupyter并集成Spark2

    Jupyter Notebook是一个Web应用程序,允许你创建和分享,包含实时的代码,可视化和解释性文字。常用于数据的清洗和转换、数值模拟、统计建模、机器学习...

    Fayson
  • Python3通过JDBC访问非Kerberos环境的Impala

    在前面Fayson介绍了在Python2的环境下《如何使用Python Impyla客户端连接Hive和Impala》及《Python3环境通过JDBC访问非K...

    Fayson
  • Linux下非常强大的MySQL命令行客户端工具(支持自动补全)

    IDO老徐
  • (十七) 初遇python甚是喜爱之pip包管理工具使用

    各位读者大大们大家好,今天学习python的pip包管理工具,并记录学习过程欢迎大家一起交流分享。

    亚乐记
  • 使用Python去爬虫

    爬虫,简单说就是规模化地采集网页信息,因为网络像一张网,而爬虫做的事就像一只蜘蛛在网上爬,所以爬虫英文名就是spider。

    一只羊
  • 一个简单的例子教会您使用javap

    使用下面的命令行对NullableTest进行反编译,以java编译器生成的字节码:

    Jerry Wang
  • 一个简单的例子教会您使用javap

    使用下面的命令行对NullableTest进行反编译,以java编译器生成的字节码:

    Jerry Wang
  • 不扯概念,用例子演示什么是脏读,不可重复读,幻读?

    原子性(Atomic) 一致性(Consistency) 隔离性(Isolation) 持久性(Durability)

    Java识堂

扫码关注云+社区

领取腾讯云代金券