python hbase 读写

比眉伴天荒 2022-05-18 05:17 243阅读 0赞

**根据hbase的key值范围查询:**

for key,data in table.scan(row_start=vin+'_'+str(int(start_t)),row_stop=vin+'_'+str(int(end_t)),revers=False,limit=10000,batch_size=1000);#根据时间戳的范围取值
    d = data['cf:point']

**根据hbase的key查询** ：

rows = table.scan(row_start=imei+'_1',row_stop=imei+'_2', reverse=False,limit=10000,batch_size=1000)

**hbase读写操作:**

import time
    import json
    import happybase
    
    conn=happybase.Connection(host='',port=9090,timeout=None)
    def read_hbase():
        connection=happybase.Connection(host='',port=9090,timeout=None)
        table=connection.table('table_name')
        #row_key='20180727111642_1532661402' #根据key读value
        #info= table.row(row_key)
        #print info
        dic={} #存放到字典里
        for key,value in table.scan():
            dic[key]=value
        print len(dic)
        send_hbase(dic)
    
    def send_hbase(dic):
        table=conn.table('OBD_WIRED_LOC_2018')
        tab=table.batch() #创建batch 
        for key in dic:
            tab.put(key,{'cf:point':json.dumps(dic[key])}) #在字典里取值
        tab.send() #发送
        print 'finish'
    read_hbase()

发表评论取消回复

表情：

评论列表（有 0 条评论，243人围观）

还没有评论，来说两句吧...

相关阅读

相关 Hbase读写流程

Hbase读写流程一、写数据流程 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_a

Love The Way You Lie/ 2023年01月08日 10:24/ 0 赞/ 147 阅读

相关 hbase如何做到实时读写

hbase如何做到实时读写 ①hbase借助内存进行读写 ②K-V结构存储数据，保证数据在大量增加时，也不会影响单个数据的查询效率 ③使用索引（LSM树） ④Blo

╰半夏微凉°/ 2023年01月08日 02:27/ 0 赞/ 189 阅读

相关 Hbase为什么支持随机读写

Hbase为什么支持随机读写基于HDFS，HDFS只支持追加写，不支持随机写！随机读写：本质上还是追加写，基于版本号，实现随机写 append + 版

谁借莪１个温暖的怀抱￠/ 2023年01月08日 02:27/ 0 赞/ 253 阅读

相关 hbase 按时刻查询_HBase读写优化

![7527de2740f2076d6456b1491e009d2f.png][] ![840b3b18975dc370403c31c02ebf15d9.png][]

绝地灬酷狼/ 2023年01月01日 10:59/ 0 赞/ 166 阅读

相关 python读写文件_Python读写文件

![93f0cb76b7c3483ccd2afe7b37d9ce04.png][] python读写文件 In this tutorial, you’ll learn ho

旧城等待，/ 2022年12月07日 13:28/ 0 赞/ 366 阅读

相关 HBase：HBase架构及读写流程

本篇博文从分析HBase架构开始，首先从架构中各个组成部分开始，接着从HBase写入过程角度入手，分析HFile的Compaction合并、Region的Split分裂过程及触

深碍√TFBOYSˉ_/ 2022年10月02日 10:51/ 0 赞/ 229 阅读

相关 HBase系列(二)：HBase架构及读写流程

本篇博文从分析HBase架构开始，首先从架构中各个组成部分开始，接着从HBase写入过程角度入手，分析HFile的Compaction合并、Region的Split分裂过程及触

冷不防/ 2022年05月19日 01:57/ 0 赞/ 284 阅读

相关 python hbase 读写

根据hbase的key值范围查询: for key,data in table.scan(row_start=vin+'_'+str(int(start_t)),ro

比眉伴天荒/ 2022年05月18日 05:17/ 0 赞/ 244 阅读

相关 spark rdd 读写hbase数据

hive 作为mapreduce计算引擎，可以使用hql来操作hbase表（hbase也可以访问hive表的数据)， spark也是计算引擎，按理也是可以读写hbase数据

た入场券/ 2022年04月13日 02:25/ 0 赞/ 317 阅读

相关 HBase（一）HBase的读写流程

> Region是HBase数据存储和管理的基本单位。在HBase的一个表中，可以包含一个或多个region。对于一个region，每个列族都会对应一个store，用来存储该列

谁践踏了优雅/ 2021年11月08日 19:16/ 0 赞/ 411 阅读