초보자를 위한 Redis Streams

Redis는 가장 유행하는 키 값 데이터베이스 저장소입니다.Redis는 대부분의 대규모 애플리케이션에 사용됩니다.
대규모 분포식 시스템을 구축할 때 우리는 한 시스템에서 다른 시스템으로 대량의 데이터 섭취나 데이터 전송을 실행해야 하는 상황을 자주 만난다.유일하게 실행 가능한 방법은 흐르는 미디어를 통과하는 것이다.분산 엔지니어는 일반적으로 아파치 카프카 등 흐름 소프트웨어를 사용하여 데이터 흐름과 수신을 수행한다.
버전 5.0을 지원하는 Redis는 혁신적인 흐름 관리 방식을 제공합니다.Redis Stream은 내장된 기능으로 데이터 구조를 제공합니다. 개발자는 이를 이용하여 데이터 섭취, 데이터 소비, 생산자와 소비자 간의 데이터 채널을 만들 수 있습니다.
이 강좌에서 우리는 Redisstreams를 어떻게 사용하는지, 그리고 분포식 시스템 엔지니어로서 Redisstreams를 어떻게 당신의 체계 구조에 통합시키는지 탐색할 것입니다.

Redis streams 기능

Redis는 전체 시스템의 다양한 용례에 사용됩니다.이것은 내용 캐시, 실시간 분석, 메시지 에이전트 등을 포함한다.
Redis는 게시/구독 기능을 제공하지만 Redis streams가 출시되면서 다음과 같은 기능을 제공합니다.

대량의 데이터를 수집한다.

많은 소비자와 생산자 사이에 데이터 채널을 만든다.

데이터 섭취율과 데이터 소모율이 다르더라도 데이터 정렬을 효과적으로 관리할 수 있다.

오프라인 데이터 지속성 지원.

생산자와 소비자 간의 비동기 통신.

대량 생산 업체와 소비자로 확장하기 쉽다.

앞에서 설명한 대로 Redis 흐름은 Redis에 배치됩니다.너는 복잡한 소프트웨어를 추가로 설치하거나 관리할 필요가 없다.Redis에 있습니다.
Redis streams에 직접 들어가 어떻게 사용하는지 배워봅시다.

Redis Streams 사용

Redis Streams는 로그 기반 데이터 구조만 추가됩니다.Redis streams는 흐름에 데이터, 소비 흐름을 추가하고 데이터 소비 방식을 관리하는 명령을 제공합니다.
Redis 흐름은 생산자와 소비자 간에 일대일 통신 또는 일대다 또는 다중 통신 흐름을 진행할 수 있다.Redis streams는 또한 소비자층을 위해 서비스를 제공하기 때문에 그들은 응당 받아야 할 정보만 소비할 수 있다.
Redis streams 명령을 사용합니다.시스템에 Redis 5.0 이상의 버전이 설치되어 있다고 가정합니다.없는 경우 최신 버전의 Redis를 다운로드하려면 Redis download page로 이동합니다.
Redis 설치가 완료되면 시스템에서 Redis 서버를 사용하고 있는 경우 다음 명령을 사용하여 Redis 서버를 시작합니다.

redis-server

일부 설치 프로그램은 이미 백그라운드에서 Redis 서버를 실행하고 있기 때문에 오류가 발생하면 걱정하지 마십시오.
이제 다음 명령을 사용하여 Redis 명령행 셸을 시작합니다.

redis-cli

Redis streams에 데이터를 추가합니다.기본값과 간단한 방법은 이 명령을 실행하는 것입니다.

XADD mystream * name Shahid

여기서 mystream은 흐름의 이름입니다.Name 은 키이고 Shahid 는 값입니다.
이 명령을 실행하면 Redis에서 흐름 데이터에 대한 ID를 생성합니다.

레코드를 추가하는 동시에 ID를 추가할 수도 있습니다.예:

XADD mystream 10000000 name Shahid

그러나 시스템에서 생성한 고유 ID에 의존해야 합니다.
Redis 흐름의 데이터를 사용합니다.
흐름의 시작부터 끝까지 모든 내용을 읽으려면 다음 명령을 사용할 수 있습니다.

XREAD STREAMS mystream 0

여기서 우리는 흐름의 이름과 시작 색인, 즉 0을 제시했다.이 명령은 흐름에 존재하는 모든 기록을 되돌려줍니다.

우리는 또한 기록 계수를 제공함으로써 기록을 제한할 수 있다.

XREAD COUNT 100 STREAMS mystream 0

XRANGE 명령을 반복해서 사용할 수도 있습니다.
예:

XRANGE mystream 1518951123450-0 1518951123460-0

위에 표시된 명령은 명령에 언급된 ID 사이의 흐름에서 레코드를 읽습니다.
레코드의 ID를 모르는 경우 COUNT 연산자를 사용하여 레코드의 수를 선택할 수 있습니다.

XRANGE mystream - + COUNT 10

위에 표시된 명령은 흐름에서 교체된 10개 기록의 기록을 되돌려줍니다.
Redis streams는 더 많은 명령과 방법을 제공하여 흐름을 관리합니다.documentation 페이지에서 자세한 내용을 확인할 수 있습니다.