redis管道

pipe = self.r.pipeline()
for news_id in news_id_list:
    pipe.hgetall(self.redis_key_prefix.format(news_id))
for i, news_action_info in enumerate(pipe.execute()):
    pass