Redis Stream

Stream

• Stream은 로그 데이터를 처리하게위해 5.0에서 새로 도입된 데이터 타입입니다.
• 대량의 데이터가 연속적으로 발생할때 처리하기 위해 등장했습니다.
• 기존 데이터를 수정하지 않고 오직 추가로 발생합니다.
• 이런 종류의 데이터를 stream or log데이터라고 합니다.

XADD : 데이터 추가

XADD key ID field value [field2 value2...]

XADD sensor-1234 * temperature 98.7

• ID=* : 명령의 결과를 ID로 리턴한다.

XLEN : 데이터 길이 조회

• 정확히는 ID개수 조회

XLEN sensor-1234

XRANGE : 데이터 조회

XRANGE key start end [COUNT count]

XRANGE sensor-1234 - +
1) 1) 1538319053569-0
    2) 1) "temperature"
        2) "98.7"
2) 1) 1538319053569-1
    2) 1) "temperature"
        2) "98.8"


XRANGE key 1538319053569 1538319053569

• start=-, end=+, count로 조회 개수 지정 가능
• start, end에 특정 id지정 가능

XREAD : 데이터 읽어 오기

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]

XREAD count 1 STREAMS sensor-1234 1538322045065-0
1) 1) "sensor-1234"
    2) 1) 1) 1538322045065-1
        2) 1) "temperature"
            2) "98.8"

• count : 읽어올 데이터 개수 지정, 지정하지않으면 모든 데이터를 읽어온다
• ID : 지정한 ID의 다음 데이터를 읽어온다. 처음 데이터 읽으려면 0으로 지정

XREAD block 5000 STREAMS sensor-1234 $

• Block : 새 데이터가 들어오기를 기다렸다가 들어오면 읽어온다. 이 때는 ID로 특별히 $를 사용한다.

XDEL, XTRIM : 데이터 삭제

• XDEL ``` XDEL key ID

XDEL sensor-1234 1538322045065-0

<br>

- XTRIM

XTRIM key MAXLEN [~] count

XTRIM sensor-1234 maxlen 10 ```

• sensor-1234에 데이터가 100개 있다면 오래된 순으로 90개를 지우고 최신 데이터 10개를 남긴다.
• 특별 옵션, ~(about) : 대량의 데이터를 신속히 처리해야하는 스트림에서는 처리 지연이 발생하지 않도록 해야한다.
  • 따라서 짧은 시간에 처리할 수 있을 정도의 데이터를 삭제하는 기능이다.
  • 예) sensor-1234에 100만개의 데이터가 있다면 999,990개를 지우는데 시간이 걸린다. 이때는 데이터를 추가하거나 처리될수 없다. 이때 처리 지연이 발생할 수 있다.

---

Reference

• http://redisgate.kr/redis/command/streams.php
• https://redis.io/commands#stream