下面是使用happybase api和thrift server从python读取hbase数据的简单方法。
要在hbase服务器上启动thrift server：

/YOUR_HBASE_BIN_DIR/hbase-daemon.sh start thrift

然后从python：

import happybase

HOST = 'Hbase server host name here'
TABLE_NAME = 'MyTable'
ROW_PREFIX = 'MyPrefix'
COL_TXT = 'CI:BO'.encode('utf-8') # column family CI, column name BO (Text)
COL_LONG = 'CI:BT'.encode('utf-8') # column family CI, column name C (Long)

conn = happybase.Connection(HOST) # uses default port 9095, but provide second arg if non-default port
myTable = conn.table(TABLE_NAME)

for rowID, row in myTable.scan(row_prefix=ROW_PREFIX.encode('utf-8')): # or leave empty if want full table scan
    colValTxt = row[COL_TXT].decode('utf-8')
    colValLong = int.from_bytes(row[COL_LONG], byteorder='big')
    print('Row ID: {}\tColumn Value: {}'.format(rowID, colValTxt))
print('All Done')

正如在评论中所讨论的，如果您尝试将内容传递给spark workers，这将不起作用，因为上面的hbase连接是不可序列化的。所以只能从主程序运行这种类型的代码。如果你想办法——分享！