通过cron job将数据存入redis

Question

我想每 15 分钟通过 cron 作业将数据从 pandas 存储到 redis 中，下面是我的代码：-

我每 15 分钟使用以下代码将数据输入 pandas，并通过 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，在月底我想要它的唯一计数。

我也在使用 set 方法，假设我有大量数据，最好的方法是什么。

谁能帮帮我。

Answer 1

下面替换

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 中的键。

通过cron job将数据存入redis

storing data into redis through cron job

python

redis

python-3.x

redis-cli