Python如何连接和启动Hive

from hive_service import ThriftHivefrom thrift import Thriftfrom thrift.transport import TSocketfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocoldef ReadHiveTest(sql):try:tSocket = TSocket.TSocket('172.18.1.88',10000)tTransport = TTransport.TBufferedTransport(tSocket)protocol = TBinaryProtocol.TBinaryProtocol(tTransport)client = ThriftHive.Client(protocol)tTransport.open()client.execute(sql)return client.fetchAll()except Thrift.TException, tx:print '%s' % (tx.message)finally:tTransport.close()if __name__ == '__main__':showDatabasesSql = 'show databases'showTablesSql = 'show tables'selectSql = 'SELECT * FROM 07_jn_mysql_2'result = ReadHiveTest(selectSql)print(result[1])