сохранение данных в Redis через задание cron

Я хочу хранить данные в redis из pandas через задание cron каждые 15 минут, и ниже мой код: -

Я беру данные в pandas каждые 15 минут с кодом ниже и отправляю их в словарь redis mydict2 через задание cron.

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. По сути, я хочу хранить идентификаторы пользователей в течение всего месяца, а в конце месяца мне нужен уникальный счет.

Также я использую метод set, что может быть лучшим методом, предполагая, что у меня очень большой объем данных.

Может ли кто-нибудь помочь мне здесь.


python-3.x python redis redis-cli
person Community    schedule 09.10.2018    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Заменить ниже

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.

person ak3191    schedule 10.10.2018