设计思路：

1.程序一旦run起来，python会把mysql中最近一段时间的数据全部提取出来

2.然后实例化redis类，将数据简单解析后逐条传入redis队列

3.定时器设计每天凌晨12点开始跑

ps：redis是个内存数据库，做后台消息队列的缓存时有很大的用处，有兴趣的小伙伴可以去查看相关的文档。

# -*- coding:utf-8 -*- import MySQLdbimport scheduleimport timeimport datetimeimport randomimport stringimport redis# get the data from mysqlclass FromSql(object): def __init__(self, conn): self.conn = conn def acquire(self): cursor = self.conn.cursor() try: sql = "SELECT * FROM test WHERE TO_DAYS(NOW()) - TO_DAYS(t) <= 1" cursor.execute(sql) rs = cursor.fetchall() #print (rs) for eve in rs: print('%s, %s, %s, %s' % eve) copy_rs = rs cursor.close() return copy_rs except Exception as e: print("The error: %s" % e)class RedisQueue(object): def __init__(self, name, namespace='queue', **redis_kwargs): """The default connection parameters are: host='localhost', port=6379, db=0""" self.__db= redis.Redis(**redis_kwargs) self.key = '%s:%s' %(namespace, name) def qsize(self): return self.__db.llen(self.key) def put(self, item): self.__db.rpush(self.key, item) def get(self, block=True, timeout=None): if block: item = self.__db.blpop(self.key, timeout=timeout) else: item = self.__db.lpop(self.key) if item: item = item[1] return item def get_nowait(self): return self.get(False)if __name__ == "__main__": # connect mysqldb conn_sql = MySQLdb.connect( host = '127.0.0.1', port = 3306, user = 'root', passwd = '', db = 'test', charset = 'utf8' )def job_for_redis(): get_data = FromSql(conn_sql) data = get_data.acquire() q = RedisQueue('test',host='localhost', port=6379, db=0) for single_data in data: for meta_data in single_data: q.put(meta_data) print(meta_data) print("All data had been inserted.") """ try: schedule.every().day.at("00:00").do(job_for_redis) except Exception as e: print('Error: %s'% e)# finally:# conn.close() while True: schedule.run_pending() time.sleep(1)"""

补充知识：python定时获取汇率存入数据库

python定时任务：

我们可以使用 轻量级的第三方模块schedule。首先先安装：pip install schedule

定时任务的的小测试：

import scheduleimport time def job(): print("I'm working...") schedule.every(10).minutes.do(job) # 每隔10分钟执行一次任务schedule.every().hour.do(job) # 每隔一小时执行一次任务schedule.every().day.at("10:30").do(job) # 每天10：30执行一次任务schedule.every(5).to(10).days.do(job) # 每5-10天执行一次任务schedule.every().monday.do(job) # 每周一的这个时候执行一次任务schedule.every().wednesday.at("13:15").do(job) # 每周三13:15执行一次任务 while True: schedule.run_pending()

获取数据存入数据库：（格式可能不太对，还有一些符号。自己修改一下即可）

import pymysqlimport scheduleimport timeimport requestsimport pandasfrom sqlalchemy import create_engine#获取美元的所有外汇def job(): content = '美元' url = 'http://mit()# 每隔几分中刷新一次#schedule.every(0.1).minutes.do(job)#每天什么时候刷新schedule.every().day.at("09:29").do(job)schedule.every().day.at("09:30").do(job)#一直循环 知道满足条件执行while True: schedule.run_pending()

以上这篇Python定时从Mysql提取数据存入Redis的实现就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。