我想每15分钟通过一次cron作业将数据从熊猫存储到redis中,以下是我的代码:-
我使用下面的代码每15分钟将数据带入大熊猫,然后通过cron作业将其发送到redis字典mydict2。
import sys import pickle import redis r = redis.StrictRedis(host='localhost', port=6379, db=0) test_dict1 = results_df.set_index('user')['ua'].T.to_dict() p_mydict = pickle.dumps(test_dict1) r.set('mydict2', p_mydict)
我在键mydict2中一次又一次得到相同的输出。基本上,我想存储整个月的用户ID,并希望在月底存储唯一的ID。
另外我正在使用set方法,假设我有大量数据,这可能是最好的方法。
有人可以在这里帮我吗。
在下面替换
p_mydict = pickle.dumps(test_dict1) r.set('mydict2', p_mydict)
与
for k, v in test_dict1.items(): r.hmset(k, {"ua" : v}) print("Done adding stuff")
字典中的每个键都将是Redis中的键。