$ pip install celery

# config/celery.py
from __future__ import absolute_import, unicode_literals
from celery import Celery
import os

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings')
app = Celery('config', broker='amqp://', backend='rpc://', include=['user.tasks'])
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

$ pip install flower

$ celery -A config flower

$ sudo apt-get install rabbitmq-serve

$ sudo rabbitmqctl add_user <user> <pwd>
$ sudo rabbitmqctl set_user_tags <user> administrator
$ sudo rabbitmqctl set_permissions -p / <user> ".*"".*" ".*"

$ sudo rabbitmqctl delete_user guest
$ sudo /etc/init.d/rabbitmq-server restart

$ sudo rabbitmq-plugins enable rabbitmq_management
$ sudo /etc/init.d/rabbitmq-server restart

# config/settings

CELERY_BROKER_URL = env('CELERY_BROKER_URL')

CELERY_BROKER_URL="amqp://admin:1234@localhost:5672//"

celery -A config worker -l info

@shared_task
def send_email(mail_title, message_data, mail_to):
  email = EmailMessage(mail_title, message_data, to=[mail_to])
  email.send()
  return None

def user_email(request, pk, email):  
        domain = get_current_site(request).domain
        uidb64 = urlsafe_base64_encode(force_bytes(pk))
        token = jwt.encode({'user_pk' : pk}, SECRET_KEY, ALGORITHM).decode('utf-8')

        message_data = message(domain, uidb64, token)
        mail_title = '이메일 인증을 완료해주세요'
        mail_to = email
        
        return (mail_title, message_data, mail_to)

def message(domain, uidb64, token):
  return f"인증에 성공 하셨습니다. :-) 아래 링크 클릭해서 회원가입을 해주세요 ! \n http://{domain}/user/account/activate/{uidb64}/{token}"

def verify_resend_email(self, dto:ResendDto):
        try:
            user = User.objects.get(email=dto.email)
            user = UserService.update(dto.email, dto.resend_email)
            mail = dto.resend_email

            return {"user": user, "mail": mail, "error":False}

        except user.DoesNotExist:
            context = context_info(msg="회원가입부터 해주세요", error=True)

            return context

class FindPasswordEmailView(View):
    '''
    description: 비밀번호 찾으려는 유저의 이메일 유효성 검증, 검증 후 인증번호 이메일로 발송
    '''
    def post(self, request, *args, **kwargs):
        if request.is_ajax():
            data = self._build_vaild_email(request)
            result = UserService.vaildate_user_email(data)

            if result['error']:
                return JsonResponse(result)

            auth_num = email_auth_num()

            result['user'].auth = auth_num
            result['user'].save()

            context = UserEmailVerifyService.send_email_with_auth_num(data.email, auth_num)

            return JsonResponse(context)

    def _build_vaild_email(self, request):
        data = json.loads(request.body)

        return VaildEmailDto(
            email = data.get('email')
        )

class AuthNumConfirmView(View):
    '''
    description: 인증번호 유효성 검증, 검증 후 비밀번호 변경 view로 이동
    '''
    def get(self, request, *args, **kwargs):
        context = context_info(name=request.user.nickname)

        return render(request,'change-password.html',context)

    def post(self, request, *args, **kwargs):
        if request.is_ajax():
            data = self._build_user_confirm_info(request)
            result = UserEmailVerifyService.verify_num(data)

            if not result['success']:
                return JsonResponse(result)

            user = UserService.get_filter_auth_user(data)

            user.auth = ''
            user.save()

            request.session['auth'] = user.email
            context = context_info(result=user.email, success=True) 

            return JsonResponse(context)

    def _build_user_confirm_info(self, request):
        data = json.loads(request.body)

        return UserConfirmDto(
            email=data.get('email'),
            valid_num=data.get('valid_num')
        )

@method_decorator(csrf_exempt, name='dispatch') 
class ValidChangePwdView(View):
    '''
    description: 변경된 비밀번호 유효성 검증, 검증후 유저의 비밀번호 변경
    '''
    def get(self, request, *args, **kwargs):
        reset_pwd_form = ChangeSetPwdForm(None)
        context = context_info(forms=reset_pwd_form)

        return render(request, 'valid-change-pwd.html', context)

    def post(self, request, *args, **kwargs):
        if request.is_ajax():
            data = self._build_vaild_pwd_info(request)
            current_user = UserService.get_email_user(data.auth)
            
            auth_login(request, current_user)

            reset_pwd_form = ChangeSetPwdForm(current_user, json.loads(request.body))
            result = UserEmailVerifyService.verify_change_pwd(reset_pwd_form, current_user)
            
            return JsonResponse(result)

    def _build_vaild_pwd_info(self, request):
        return AuthDto(
            auth = request.session.get('auth'),
            user = request.user
        )

class LoginCallBackView(TemplateView):
    template_name = 'login_callback.html'

    def get(self, request, *args, **kwargs):
        context = {'message': 'SUCCESS'}
        return self.render_to_response(context)

class UserEmailVerifyService():
    @staticmethod
    def send_email_with_auth_num(email, auth_num):
        message_data = pwd_change_message(auth_num)
        mail_title = '이메일 인증을 완료해주세요'
        mail_to = email
        send_email.delay(mail_title, message_data, mail_to)
        
        context = context_info(
        msg='이메일에 인증번호를 발송했습니다!', 
        error=False, 
        auth_num=auth_num
        )

        return context

from celery.schedules import crontab

app.conf.beat_schedule = {
    'add-every-minutes-naver':{
    'task':'user.tasks.task_scrappy_naver',
    'schedule': crontab(minute='*/3'),
    },
    'add-every-minutes-daum':{
    'task':'user.tasks.task_scrappy_daum',
    'schedule': crontab(minute='*/5'),
    }
}

$ celery -A config beat -l info