Python에서 Redis 적용

Redis는 캐시, 메시지 큐, 카운터 및 기타 시나리오에서 일반적으로 사용되는 오픈 소스 고성능 키-값 스토리지 시스템입니다. 간결하고 효율적인 스크립팅 언어인 Python은 웹 백그라운드 처리, 데이터 분석 및 마이닝, 기계 학습, 인공 지능 및 기타 분야에서도 널리 사용됩니다. 이 기사에서는 Redis 설치, Python Redis 클라이언트 모듈 사용 및 특정 적용 사례를 포함하여 Python에서 Redis를 적용하는 방법에 대해 설명합니다.

1. Redis 설치

1. 설치 파일 다운로드
   Redis 공식 홈페이지에서는 소스코드와 미리 컴파일된 버전을 제공합니다. 미리 컴파일된 버전을 선택하면 최신 버전을 직접 다운로드할 수 있습니다.
2. 압축해제 및 컴파일
   다운로드가 완료된 후 지정된 디렉터리에 압축을 풀어주세요. make 명령을 사용하여 Redis를 실행 파일, 시작 스크립트 등으로 컴파일합니다. Linux 시스템에서는 다음 명령을 사용할 수 있습니다.

$ tar xzf redis-5.0.3.tar.gz
$ cd redis-5.0.3
$ make

3. Redis 서버 시작
   컴파일이 완료된 후, redis를 사용할 수 있습니다. -server 명령은 Redis 서버를 시작합니다. 기본 수신 포트는 6379입니다.

$ src/redis-server

4. 연결 테스트
   redis-cli 명령을 사용하여 Redis 서버에 연결할 수 있습니다. 작동을 위해. 예를 들어 SET 명령을 사용하여 키-값 쌍을 설정합니다.

$ src/redis-cli
127.0.0.1:6379> SET mykey "Hello Redis"
OK
127.0.0.1:6379> Hello Redis"

Redis 서버에 연결
1. 먼저 Redis 서버에 연결하기 위한 Redis 객체를 생성해야 합니다. 다음 코드를 사용할 수 있습니다:
   

rds = redis.Redis(host='localhost', port=6379, db=0)

데이터 작업
2. Redis 객체를 사용하여 키-값 쌍 및 기타 작업을 설정, 획득, 삭제합니다. 예:
   

name = rds.get('name')
print(name) # 출력: b'Alice'

일괄 작업
3. 효율성 향상을 위해 Redis는 일괄 작업을 지원합니다. 파이프라인을 사용하면 여러 작업을 패키지화하여 Redis 서버로 전송할 수 있으므로 네트워크 오버헤드와 대기 시간이 줄어듭니다. 예:
   

pipe.set('key1', 'value1')
pipe.set('key2', 'value2')
pipe.set('key3', 'value3 ' )
pipe.execute()

Pub/Sub 모드
4. Redis는 메시지 전송을 위한 게시/구독 모드를 제공합니다. Python Redis 클라이언트 라이브러리는 해당 API도 제공합니다. 예:
   

pubsub = rds.pubsub()
pubsub.subscribe('channel')
rds.publish('channel', 'Hello')
time.sleep(1) # 1초 동안 기다립니다.
msg = pubsub.get_message()
print(msg) # 출력: {'type': 'message', 'channel': b'channel', 'data': b'Hello'}

Caching
1. Python Redis 클라이언트 라이브러리를 사용하면 일반적으로 사용되는 데이터를 캐시하고 웹 응용 프로그램의 응답 속도를 높일 수 있습니다. 예:
   

import redis
class Cache:

def __init__(self):
    self.rds = redis.Redis(host='localhost', port=6379, db=0)

def get(self, key):
    val = self.rds.get(key)
    if val:
        return val.decode()
    return None

def set(self, key, val, ttl=60):
    self.rds.set(key, val, ex=ttl)

val = 캐시.get('key')
val이 아닌 경우:

# 从数据库中查询数据
val = 'value'
cache.set('key', val, ttl=60)

분산 잠금
2. 분산 잠금은 여러 프로세스/스레드/노드가 협력할 때 리소스 경쟁을 피하기 위해 사용되는 동기화 메커니즘입니다. Python Redis 클라이언트 라이브러리를 사용하여 분산 잠금을 구현할 수 있습니다. 예:
   

import redis
class Lock:

def __init__(self):
    self.rds = redis.Redis(host='localhost', port=6379, db=0)
    self.locked = False

def acquire(self, lockname, ttl=60):
    identifier = str(time.time())
    self.locked = self.rds.setnx(lockname, identifier)
    if self.locked:
        self.rds.expire(lockname, ttl)
    return self.locked

def release(self, lockname):
    if self.locked:
        self.rds.delete(lockname)

if lock.acquire('mylock'):

# 处理业务逻辑...
lock.release('mylock')

위 내용은 Python에서 Redis 적용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!