automation

Cron scheduling is nothing new. It is basically a concept in which the system keeps executing lines of code every few seconds, minutes, or hours. It is required in many large applications which require some automation in their working. I had to use it for two purposes in our Open-Event application. To automatically delete the items in the trash after a period of 30 days. To automatically send after event mails to the speakers and organizers when an event gets completed 1. Delete items in Trash system So the deleted items get stored in the trash of the admin. However if the items are not deleted or no action is performed on them then they should be deleted automatically if they stay in the trash for more than 30 days. I have used a framework - apscheduler (Advanced Python Scheduler) for this.The code is like this from apscheduler.schedulers.background import BackgroundScheduler def empty_trash(): with app.app_context(): print 'HELLO' events = Event.query.filter_by(in_trash=True) users = User.query.filter_by(in_trash=True) sessions = Session.query.filter_by(in_trash=True) for event in events: if datetime.now() - event.trash_date >= timedelta(days=30): DataManager.delete_event(event.id) for user in users: if datetime.now() - user.trash_date >= timedelta(days=30): transaction = transaction_class(Event) transaction.query.filter_by(user_id=user.id).delete() delete_from_db(user, "User deleted permanently") for session in sessions: if datetime.now() - session.trash_date >= timedelta(days=30): delete_from_db(session, "Session deleted permanently") trash_sched = BackgroundScheduler(timezone=utc) trash_sched.add_job(empty_trash, 'cron', day_of_week='mon-fri', hour=5, minute=30) trash_sched.start() The trash_sched is initialized first. It is given an instance of BackgroundScheduler() meaning it will always run in the background as long as the application server is running. The second line defines the trigger which is given to the scheduler meaning at what time intervals do we want the scheduler to execute the function. trash_sched.add_job(empty_trash, 'cron', day_of_week='mon-fri', hour=5, minute=30) Here the scheduler adds the function to the job list. The function is empty_trash and the trigger given here is 'cron'. The following line: day_of_week='mon-fri', hour=5, minute=30 sets the time at which the sheduler executes the job. The above line means that the job will be executed every day from Monday to Friday at 5:30 AM. Now coming to the function which is to be executed: def empty_trash(): with app.app_context(): events = Event.query.filter_by(in_trash=True) users = User.query.filter_by(in_trash=True) sessions = Session.query.filter_by(in_trash=True) for event in events: if datetime.now() - event.trash_date >= timedelta(days=30): DataManager.delete_event(event.id) for user in users: if datetime.now() - user.trash_date >= timedelta(days=30): transaction = transaction_class(Event) transaction.query.filter_by(user_id=user.id).delete() delete_from_db(user, "User deleted permanently") for session in sessions: if datetime.now() - session.trash_date >= timedelta(days=30): delete_from_db(session, "Session deleted permanently") There are three items in the trash: events, users and sessions. We get all the items in the trash by the query.all() method. Each model: Events, Users and Sessions has a column trash_date = db.Column(db.DateTime) The date on which the item is moved to the trash is stored in the trash_date column. And the following line: if datetime.now() - event.trash_date >= timedelta(days=30) checks if the item has been in the trash for more than 30 days. If yes then it is deleted automatically. This function is constantly executed by the apscheduler according to the time settings given by us. Thus we do…