almacenamiento de datos en redis a través del trabajo cron

Quiero almacenar datos en redis desde pandas a través de un trabajo cron cada 15 minutos y debajo está mi código: –

Estoy tomando datos en pandas cada 15 minutos con el siguiente código y los envío al diccionario redis mydict2 a través de un trabajo 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) 

Estoy obteniendo la misma salida una y otra vez en la clave mydict2. Básicamente, quiero almacenar los identificadores de usuario para todo el mes y al final del mes quiero el recuento único de eso.

También estoy usando el método set, ¿cuál podría ser el mejor método suponiendo que tengo una gran cantidad de datos?

¿Puede alguien ayudarme aquí?

Reemplazar a continuación

 p_mydict = pickle.dumps(test_dict1) r.set('mydict2', p_mydict) 

con

  for k, v in test_dict1.items(): r.hmset(k, {"ua" : v}) print("Done adding stuff") 

y cada clave en tu diccionario será una clave en Redis.