python连接redis数据库

python连接redis数据库

• Python的第三方库
• 1. 初始化并创建连接
• • • 1.1 第一种方法 （普通）
    • 1.2 第二种方法 （连接池）
• 2. 写入数据
• • • 2.1 向字符串中写入数据
    • 2.2 设置多个键值
• 3. 创建方法，传参并读取redis库中的内容
• • • 3.1 向字符串中读取数据
    • 3.2 获取多个值
    • 4. 向redis中添加一个字符串，key为kingname，value为现在时间

Python的第三方库

pip install redis

1. 初始化并创建连接 1.1 第一种方法 （普通）

import redis
pool = redis.ConnectionPool(host="***", port=***, password='***', db=***)
redis_conn= redis.Redis(connection_pool=pool)

1.2 第二种方法 （连接池）

import redis
redis_conn= redis.Redis(host='***', port= ***, password= '***', db= ***)

2. 写入数据 2.1 向字符串中写入数据

 # redis_conn.set(key,value)
 redis_conn.set('ywm', 'test1')

2.2 设置多个键值

 # hmset key FIELD1 VALUE1 ...FIELDN VALUEN  
 redis_conn.hmset('ywm6', {'k1':'v1', 'k2': 'v2'})

3. 创建方法，传参并读取redis库中的内容

def read_redis(redis_conn, d_id):
        redis_key = 'pact-fileparse-%s' % d_id
        redis_value = eval(redis_conn.get(redis_key).decode("utf-8"))[1][0]
        json_data = json.loads(redis_value)
        json.dump(json_data, open(raw_data_path, 'w', encoding='utf-8'), indent=4, ensure_ascii=False)

3.1 向字符串中读取数据

 # redis_conn.get(key)
 redis_conn.get('ywm')

3.2 获取多个值

 # hmset key FIELD1 ...FIELDN
 redis_conn.hmget('ywm6', 'k1', 'k2')

4. 向redis中添加一个字符串，key为kingname，value为现在时间

 import redis
 import datetime
 redis_conn= redis.Redis(host='***', port= ***, password= '***', db= ***)
 now= datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
 redis_conn.set('ywm',now)