我有大约 20 亿个键值对,我想将它们高效地加载到 Redis 中。我目前正在使用 Python,并使用了redis-py记录的 Pipe 。如何加快以下方法的速度?
import redis
def load(pdt_dict):
"""
Load data into redis.
Parameters
----------
pdt_dict : Dict[str, str]
To be stored in Redis
"""
redIs = redis.Redis()
pipe = redIs.pipeline()
for key in pdt_dict.keys():
pipe.hmset(self.seller + ":" + str(key), pdt_dict[key])
pipe.execute()