检测asp网站死循环,有没有如何做网站的书,有没有专门做平铺素材的网站,谷歌网页配置 thrift
python使用的包 thrift
个人使用的python 编译器是pycharm community edition. 在工程中设置中#xff0c;找到project interpreter#xff0c; 在相应的工程下#xff0c;找到package#xff0c;然后选择 “” 添加#xff0c; 搜索 hbase-thrift (Python cl…配置 thrift
python使用的包 thrift
个人使用的python 编译器是pycharm community edition. 在工程中设置中找到project interpreter 在相应的工程下找到package然后选择 “” 添加 搜索 hbase-thrift (Python client for HBase Thrift interface),然后安装包。
安装服务器端thrift。
参考官网同时也可以在本机上安装以终端使用。
thrift Getting Started
也可以参考安装方法 python 调用HBase 范例
首先安装thrift
下载thrift这里我用的是thrift-0.7.0-dev.tar.gz 这个版本
tar xzf thrift-0.7.0-dev.tar.gz
cd thrift-0.7.0-dev
sudo ./configure –with-cppno –with-rubyno
sudo make
sudo make install
然后到HBase的源码包里找到
src/main/resources/org/apache/hadoop/hbase/thrift/
执行
thrift –gen py Hbase.thrift
mv gen-py/hbase/ /usr/lib/python2.4/site-packages/ (根据python版本可能有不同)
获取数据示例 1# coding:utf-8
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from hbase import Hbase
# from hbase.ttypes import ColumnDescriptor, Mutation, BatchMutation
from hbase.ttypes import *
import csv
def client_conn():
# Make socket
transport TSocket.TSocket(hostname,like:localhost, port)
# Buffering is critical. Raw sockets are very slow
transport TTransport.TBufferedTransport(transport)
# Wrap in a protocol
protocol TBinaryProtocol.TBinaryProtocol(transport)
# Create a client to use the protocol encoder
client Hbase.Client(protocol)
# Connect!
transport.open()
return client
if __name__ __main__:
client client_conn()
# r client.getRowWithColumns(table name, row name, [column name])
# print(r[0].columns.get(column name)), type((r[0].columns.get(column name)))
result client.getRow(table name,row name)
data_simple []
# print result[0].columns.items()
for k, v in result[0].columns.items(): #.keys()
#data.append((k,v))
# print type(k),type(v),v.value,,v.timestamp
data_simple.append((v.timestamp, v.value))
writer.writerows(data)
csvfile.close()
csvfile_simple open(data_xy_simple.csv, wb)
writer_simple csv.writer(csvfile_simple)
writer_simple.writerow([timestamp, value])
writer_simple.writerows(data_simple)
csvfile_simple.close()
print finished
会基础的python应该知道result是个listresult[0].columns.items()是一个dict 的键值对。可以查询相关资料。或者通过输出变量观察变量的值与类型。
说明上面程序中 transport.open()进行链接在执行完后还需要断开transport.close()
目前只涉及到读数据之后还会继续更新其他dbase操作。
以上就是详解python操作hbase数据的方法介绍的详细内容更多请关注Gxl网其它相关文章
本条技术文章来源于互联网如果无意侵犯您的权益请点击此处反馈版权投诉
本文系统来源php中文网
TAG标签python
