python如何连接hive

pip install pyhs2

hive --service hiveserver

#!/usr/bin/python

# -*- coding: UTF-8 -*-

import pyhs2

with pyhs2.connect(host='10.104.111.33',

                   port=10000,

                   authMechanism="PLAIN",

                   user='bestfei',

                   password='password',

                   database='default') as conn:

    with conn.cursor() as cur:

        #Show databases

        print "cur.getDatabases"

        print cur.getDatabases()

        print "-"*40

        #Execute query

        cur.execute("show databases")

        #Return column info from query

        print cur.getSchema()

        print "-"*40

        #Fetch table results

        for i in cur.fetch():

            print i