python hbase 读写

比眉伴天荒 2022-05-18 05:17 260阅读 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 条评论，260人围观）

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

相关阅读

相关 Flink 读写 HBase 总结

总结 Flink 读写 HBase本文总结了Flink SQL 读写 HBase 的参数配置，解决了在kerberos环境下因 hudi 包 hbase-site.xml...

妖狐艹你老母/ 2024年05月31日 06:05/ 0 赞/ 111 阅读

相关 HBase的读写流程

HBase的读写流程 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9

小鱼儿/ 2024年02月19日 19:31/ 0 赞/ 83 阅读

相关 HBase读写流程

HBase读写流程架构原理 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0

妖狐艹你老母/ 2023年10月04日 16:42/ 0 赞/ 70 阅读

相关 HBase的读写机制

HBase写数据流程 1、Client先访问zookeeper，从meta表获取相应region信息，然后找到meta表的数据 2、根据namespace、表名和rowke

雨点打透心脏的1/2处/ 2023年02月12日 06:27/ 0 赞/ 12 阅读

相关 Hbase读写流程

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

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

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

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

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

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

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

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

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

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

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

相关 python hbase 读写

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

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

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

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

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