HBase rowkey设计实例
需求:绘制渠道用户的每日趋势(每分钟一组数据一天1440组,2000+个渠道,区分新/老用户,2*1440*2000+=576万+/每天),需要保存90天。 查询条件:渠道号、新or老用户、日期 rowkey:渠道_日期_新or老用户_小时分钟(hhmm) 连接HBase from thrift.protocol import TBinaryProtocol from thrift.transport import TSocket from thrift.transport import TTransport from hbase import Hbase def hbase_connect(): transport = TSocket.TSocket('*', 9090) # transport = TSocket.TSocket('10.50.14.105', 9090) hbase_transport = TTransport.TBufferedTransport(transport) protocol = TBinaryProtocol.TBinaryProtocol(tra...

