HBase(分布式、面向列、非结构化数据存储,基础框架,设计和操作)总结

2024年2月8日发(作者：)

print('show value of row named %s' % row_keys) if len(row_keys) == 1: print (row_keys[0]) else: print (row_keys) else: print('show all row values of table named %s' % ) for key, value in (): print key, value def put_row(table, column_family, row_key, value): print('insert one row to hbase') # column_family:qualifier:value # column_qualifier = name

(row_key, {'%s:name' % column_family:'name_%s' % value}) def put_rows(table, column_family, row_lines=30): print('insert rows to hbase now') for i in range(row_lines): put_row(table, column_family, 'row_%s' % i, i) def delete_row(table, row_key, column_family=None, keys=None): if keys: print('delete keys:%s from row_key:%s' % (keys, row_key)) key_list = ['%s:%s' % (column_family, key) for key in keys] (row_key, key_list) else: print('delete row(column_family:) from hbase') (row_key) def delete_table(table_name): pretty_print('delete table %s now.' % table_name) _table(table_name, True) def main(): table = (table_name) show_rows(table) put_rows(table, column_family) show_rows(table) #

更新操作 # put_row(table, column_family, row_key, '') # show_rows(table, [row_key]) #

删除数据 # delete_row(table, row_key) # show_rows(table, [row_key]) # delete_row(table, row_key, column_family, ['name']) # show_rows(table, [row_key]) # delete_table(table_name) if __name__ == "__main__": main()