EsupPortail / Esup-Pod / 8023477126

from celery import Celery

from tempfile import NamedTemporaryFile

import logging

import os

import requests

try:

    from ..custom import settings_local

except ImportError:

    from .. import settings as settings_local

logger = logging.getLogger(__name__)

EMAIL_HOST = getattr(settings_local, 'EMAIL_HOST', "")

DEFAULT_FROM_EMAIL = getattr(settings_local, 'DEFAULT_FROM_EMAIL', "")

ADMINS = getattr(settings_local, 'ADMINS', ())

DEBUG = getattr(settings_local, 'DEBUG', True)

admins_email = [ad[1] for ad in ADMINS]

if DEBUG:

    logger.setLevel(logging.DEBUG)

smtp_handler = logging.handlers.SMTPHandler(

logger.addHandler(smtp_handler)

POD_API_URL = getattr(

POD_API_TOKEN = getattr(

ENCODING_TRANSCODING_CELERY_BROKER_URL = getattr(

transcripting_app = Celery(

transcripting_app.conf.task_routes = {

transcripting_app.autodiscover_tasks(packages=None, related_name="", force=False)

@transcripting_app.task

def start_transcripting_task(video_id, mp3filepath, duration, lang):

    from .transcript_model import start_transcripting

    from ..main.settings import MEDIA_ROOT

    print("Start the transcripting of the video %s" % video_id)

    print(video_id, mp3filepath, duration, lang)

    msg, text_webvtt = start_transcripting(mp3filepath, duration, lang)

    print("End of the transcripting of the video")

    media_temp_dir = os.path.join(MEDIA_ROOT, "temp")

    if not os.path.exists(media_temp_dir):

        os.mkdir(media_temp_dir)

    temp_vtt_file = NamedTemporaryFile(dir=media_temp_dir, delete=False, suffix=".vtt")

    text_webvtt.save(temp_vtt_file.name)

    print("End of the transcoding of the video")

    Headers = {"Authorization" : "Token %s" % POD_API_TOKEN}

    url = POD_API_URL.strip("/") + "/store_remote_transcripted_video/?id=%s" % video_id

    data = {

    try:

        response = requests.post(url, json=data, headers=Headers)

        if response.status_code != 200:

            msg = "Calling store remote transcoding error : {} {}".format(

            logger.error(msg + "\n" + str(response.content))

            logger.info("Call importing transcript task ok")

    except (

        msg = "Exception: {}".format(type(exception).__name__)

        msg += "\nException message: {}".format(exception)

        logger.error(msg)