如何通过pyhs2通过python连接到hadoop配置单元?

vcudknz3  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(199)

我已经安装了 Hadoop 生态系统开启 OS X . 我已经安装了 pyhs2 python包,以便连接到hive并查询数据库。我使用的代码如下:

import pyhs2

with pyhs2.connect(host='127.0.0.1',
                   port=10000,
                   authMechanism="PLAIN",
                   user='admin',
                   password='1234qwer',
                   database='cards') as conn:
    with conn.cursor() as cur:
        #Show databases
        print cur.getDatabases()

        #Execute query
        cur.execute("select * from users")

        #Return column info from query
        print cur.getSchema()

        #Fetch table results
        for i in cur.fetch():
            print i

hive 配置文件 /usr/local/opt/hive/libexec/conf/hive-default.xml 我已经准备好了 username 以及 passwordadmin 以及 1234qwer .
现在,当我运行python脚本时,会出现以下错误:

thrift.transport.TTransport.TTransportException: Could not connect to 127.0.0.1:10000

堆栈溢出中的类似问题:
如何使用python pyhs2连接到配置单元?
我可以去 hive 通过终端,一切正常。
奇怪的是我用 lsof -i -P | grep -i 'listen'" 但是港口没有列在那里!
有什么帮助吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题