...

class WebhookView(generics.CreateAPIView):
    permission_classes = [AllowAny]
    parser_classes = [BodyParser]
    
    def post(self, request):
        logger.info('Received webhook request')
        .........
        logger.info('process_event webhook request')
        process_event.delay_on_commit(event)
        return Response(status=200)

@shared_task
def process_event(event):
    logger.info(event.type)
    event_id = event['id']
    if ProcessedEvent.has_processed_event(event_id):
        logger.info(f'Event {event_id} already processed')
        return

import os
from celery import Celery
from celery.utils.log import get_task_logger
from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'main.settings')

app = Celery('main')

app.config_from_object('django.conf:settings', namespace='CELERY')

app.autodiscover_tasks()
app.conf.broker_connection_retry_on_startup=True
app.conf.worker_cancel_long_running_tasks_on_connection_loss=True,

# Celery
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/1'
CELERY_TIMEZONE = TIME_ZONE
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
# ASGI and Channels
ASGI_APPLICATION = "main.asgi.application"
CHANNEL_LAYERS = {
    "default": {
        "BACKEND": "channels_redis.core.RedisChannelLayer",
        "CONFIG": {
            "hosts": [('redis://localhost:6379/2')],
        },
    },
}