mysql.py 文件源码

def start_update_engagement():
    def update_job():
        with DBSession() as session:
            for engagement in session.query(Engagement).all():
                en = json.loads(engagement.engagement)
                en.append(0)
                engagement.engagement = json.dumps(en)
                session.add(engagement)
                session.commit()

    schedule.every().day.at('00:00').do(update_job)