from __future__ import absolute_import, unicode_literals
from rest_framework.response import Response
from celery import shared_task



@shared_task
def backup_database():
    """
    备份数据库
    """
    import os
    ret = os.popen('sudo pg_dump -U postgres -d hberp -f /home/lighthouse/hberp_backup.sql')
    return Response()

@shared_task
def reload_server():
    import os    # 更新后端  
    os.chdir('/home/lighthouse/hberp')
    ret = os.popen('sudo git pull && sudo service supervisor reload')
    return Response(ret.read())