db_update.py

from celery import Celery
from celery.schedules import crontab
import MySQLdb


app = Celery('db_update', broker="pyamqp://guest@localhost//")
# disable UTC to use local time
app.conf.enable_utc = False


@app.task
def update_data():
    try:
        db = MySQLdb.connect(user='root', passwd="qweqwe", db="celery_test")
        c = db.cursor()
        c.execute("""INSERT INTO `student_old` (`id`, `name`, `email`, `address`, `class`) VALUES (NULL, 'new user', NULL, NULL, NULL)""")
        db.commit()
        db.close()

    except Exception as e:
        print(str(e))


# add "update_data" task to the beat schedule
app.conf.beat_schedule = {
    "sync-db": {
        "task": "db_update.update_data",
        "schedule": crontab(minute='*'),
    }
}