python redis 批量插入

在对于百万级的key 插入时, 考虑使用pipeline 批量插入的方式,话不多说,上代码:

pipeline_redis = init_redis_pool(12).client().pipeline()
len_ = len(list_)
count = 0
for key in list_:
    

    id_dict[key] = n
    n += 1
    name = "{}:{}".format("id", n)

    count += 1

    pipeline_redis.set(name, str(len_dict))

    if count % 10000 == 0:

        pipeline_redis.execute()
        print("总数{}, 已处理 {}".format(len_, n))
        count = 0

pipeline_redis.execute()


版权声明:本文为ty2009137128原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。