python+MySQL定时备份前一天的数据

import logging
 
import requests
from apscheduler.schedulers.background import BlockingScheduler
 
logging.basicConfig(level=logging.INFO)
 
LOCAL_PORT = 4000
LOCAL_HOST = '127.0.0.1'
 
 
def loop_export_task():
    url = "http://{}:{}/data/export".format(LOCAL_HOST, LOCAL_PORT)
    logging.info(url)
    r = requests.get(url)
    logging.info(r.text)
 
 
if __name__ == '__main__':
    scheduler = BlockingScheduler(timezone="Asia/Shanghai")
    # 每天凌晨1点执行
    scheduler.add_job(loop_export_task, 'cron', day_of_week='*', hour='1', minute='0', second='0')
    scheduler.start()
    logging.info('The Next Run Time is: ', scheduler.get_jobs()[0].next_run_time)

@bp.route('/data/export')
def export_data():
    ipmac_sql = """
    select macaddr, recordtime, eventdetail, eventtype, ipaddr, pkttime, CONCAT(packet,'') as packet,
    starttime, count_num, action, hashid as hash_id, endtime
    from events_ipmac where date(recordtime)=date_sub(curdate(),interval 1 day);
    """
 
 
    sql_list = [ipmac_sql,]
    timestamp = int(time.time())
    _, result = pool_connect_db.select_all(sql)
    filepath = os.path.join(BASE_PATH, 'ipmac_sql')
    if not os.path.exists(filepath):
        os.makedirs(filepath)
    with open('%s/data.json' % filepath, 'wb') as _file:
        json.dump(result, _file)
    return jsonify({'code': 200, 'msg': 'export data success'})