使用Python访问Hive数据

您可以使用hive库从python访问hive，因为要从hive导入ThriveHive导入hive类

下面的例子

import sysfrom hive import ThriftHivefrom hive.ttypes import HiveServerExceptionfrom thrift import Thriftfrom thrift.transport import TSocketfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocoltry:  transport = TSocket.TSocket('localhost', 10000)  transport = TTransport.TBufferedTransport(transport)  protocol = TBinaryProtocol.TBinaryProtocol(transport)  client = ThriftHive.Client(protocol)  transport.open()  client.execute("CREATE TABLE r(a STRING, b INT, c DOUBLE)")  client.execute("LOAD TABLE LOCAL INPATH '/path' INTO TABLE r")  client.execute("SELECt * FROM r")  while (1):    row = client.fetchOne()    if (row == None):       break    print row  client.execute("SELECt * FROM r")  print client.fetchAll()  transport.close()except Thrift.TException, tx:  print '%s' % (tx.message)