celery.py

# -*- coding: utf-8 -*-

from celery import Celery
from kombu import Exchange, Queue
import time

# Celery Config

hastane_app = Celery()
celeryconfig = {}
celeryconfig['BROKER_URL'] = 'amqp://user:password@localhost:5672/%2f'
celeryconfig['CELERY_QUEUES'] = (
    Queue('tasks', Exchange('tasks'), routing_key='tasks',
          queue_arguments={'x-max-priority': 10}),
)
celeryconfig['CELERY_ACKS_LATE'] = True
celeryconfig['CELERYD_PREFETCH_MULTIPLIER'] = 1
hastane_app.config_from_object(celeryconfig)


@hastane_app.task
def kafa_tramvasi():
    print("Kafa Tramvasi tedavi ediliyor..")
    time.sleep(10)
    print("Kafa Tramvasi tedavi edildi..")


@hastane_app.task
def kirik_cikik():
    print("Alciya aliniyor..")
    time.sleep(5)
    print("Alciya alindi")


@hastane_app.task
def estetik():
    print("Estetik İslem Basladi..")
    time.sleep(8)
    print("Estetik İslem Bitti..")