本文介绍python中操作redis的方法

更新于 2021-11-14

安装

首先需要安装redis包：

1
$ pip install redis

代码

这里将redis操作都放到了一个类中：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#!/usr/bin/env python
# -*- coding: utf-8 -*-

import redis


class RedisOperator(object):
    '''
        redis相关操作
    '''

    def __init__(self):
        self.redis_host = '1.1.1.1'
        self.redis_port = '6379'
        self.redis_pass = 'redis123'
        self.redis_db = 0
        self.redis_extime = 60	# 过期时间，不设置就永不过期

    def __connect(self):
        '''连接redis'''
        redis_host = self.redis_host
        redis_port = self.redis_port
        redis_pass = self.redis_pass
        redis_db = self.redis_db

        redis_db_url = {
            'host': redis_host,
            'port': redis_port,
            'password': redis_pass,
            'db': redis_db
        }

        return redis.Redis(**redis_db_url)

    def get_redis_data(self, key):
        '''查询key值，如果key不存在则返回None'''
        conn = self.__connect()
        data = conn.get(key)

        return data

    def set_redis_data(self, key, value):
        '''设置键值对，如果键值对已经存在则覆盖原来的值'''
        conn = self.__connect()
        data = value
        conn.set(
            name = key,
            value = data,
            ex = self.redis_extime
        )

        return 0