hbase command

• nosql

• sell 실행 hbase shell

• create table create 'students', 'info'

• table 조회 list

• Create

  • 1번 학생의 이름과 나이
  • 2번 학생의 이름과 주소

put 'students', '1', 'info:name', 'ruka'
put 'students', '1', 'info:age', '23'
put 'students', '2', 'info:name', 'asa'
put 'students', '2', 'info:address', 'tokyo'

• Read
  • 1
  • all

get 'students', '1'
scan 'students'

• Update

put 'students', '2', 'info:address', 'seoul'

• Delete
  • 해당 컬럼 삭제
  • 전체 컬럼 삭제

delete 'students', '2', 'info:address'
deleteall 'students', '1'

• drop table

disable 'students'
drop 'students'

채팅 서비스 모델링

• create table

create 'chatrooms', 'info'
create 'messages', 'info'

• 채팅방 생성

put 'chatrooms', 'room1', 'info:name', 'python chatroom'
put 'chatrooms', 'room2', 'info:name', 'finance chatroom'

• 메시지 전송

put 'messages', 'room1_143900', 'info:text', 'python version?'
put 'messages', 'room1_143901', 'info:text', '3.13.2 :)'

put 'messages', 'room2_144000', 'info:text', 'tesla bad'
put 'messages', 'room2_144030', 'info:text', ':('

put 'messages', 'room1_143902', 'info:text', 'me too'
put 'messages', 'room2_144031', 'info:text', 'me too'

• 데이터 확인

scan 'messages'

• 데이터 조회
  • 출력 개수 제한
  • 특정 컬럼만 조회
  • 범위 지정 조회
  • prefix 기준 조회

scan 'messages', { LIMIT => 3 }
scan 'messages', { COLUMNS => ['info:text'] }
scan 'messages', { STARTROW => 'room1', STOPROW => 'room2' }
scan 'messages', { FILTER => "PrefixFilter('room1')" }

pyenv

pyenv install 3.11.12
pyenv versions
python -V
pyenv global 3.13.2 

ubuntu@1-14:~/damf2/hbase$ pyenv local 3.11.12 

• pyenv를 사용하여 프로젝트마다 python 버전을 다르게 사용

fastAPI ~ hbase

• fastAPI 서버 실행

uvicorn main:app --reload --port 9999

• hbase 서버 실행

bin/hbase-daemon.sh start thrift

• hbase shell

list
disable 'chatrooms'
drop 'chatrooms'
create 'chatrooms', 'info'
create 'messages', 'info'