1. import random
    2.  
    3. def create_random_type_keys(client, number):
    4.     """
    5.     在数据库中创建指定数量的类型随机键。
    6.     """
    7.     # 创建流水线对象
    8.     pipe = client.pipeline(transaction=False)
    9.     for i in range(number):
    10.         # 构建键名
    11.         key = "key:{0}".format(i)
    12.         # 从六个键创建函数中随机选择一个
    13.         create_key_func = random.choice([
    14.             create_hash, 
    15.             create_list, 
    16.             create_set, 
    17.             create_zset, 
    18.             create_stream
    19.         ])
    20.         # 把待执行的 Redis 命令放入流水线队列中
    21.         create_key_func(pipe, key)
    22.     # 执行流水线包裹的所有命令
    23.     pipe.execute()
    24.  
    25. def create_string(client, key):
    26.     client.set(key, "")
    27. def create_hash(client, key):
    28.     client.hset(key, "", "")
    29.  
    30. def create_list(client, key):
    31.     client.rpush(key, "")
    32.  
    33. def create_set(client, key):
    34.     client.sadd(key, "")
    35.  
    36. def create_zset(client, key):
    37.     client.zadd(key, {"":0})
    38.  
    39. def create_stream(client, key):