Chneemann/videoflix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

added django rq

Browse source
This commit is contained in:
Chneemann 2024-08-19 20:39:47 +02:00
parent 6fce3f1775
commit f3a0582428
1 changed files with 7 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
backend/videoflix/content/signals.py
View file

@ -3,6 +3,7 @@ from .tasks import convert_video_to_hls, create_thumbnails, delete_original_vide
from django.dispatch import receiver from django.dispatch import receiver
from django.db.models.signals import post_save, post_delete from django.db.models.signals import post_save, post_delete
import os import os
import django_rq
import shutil import shutil
@receiver(post_save, sender=Video) @receiver(post_save, sender=Video)
@ -10,32 +11,20 @@ def video_post_save(sender, instance, created, **kwargs):
""" """
Generates a thumbnail for a newly created `Video` instance. Generates a thumbnail for a newly created `Video` instance.
""" """
# With Django RQ Worker (My server is too slow for it)
if created: if created:
queue = django_rq.get_queue("default", autocommit=True)
#Create thumbnail #Create thumbnail
create_thumbnails(instance, instance.id) create_thumbnails(instance, instance.id)
#Convert video #Convert video
for resolution in ["480", "720", "1080"]: for resolution in ["480", "720", "1080"]:
convert_video_to_hls(instance.video_file.path, resolution, instance.id) queue.enqueue(convert_video_to_hls, instance.video_file.path, resolution, instance.id)
# Delete the original video file #Delete the original video file
delete_original_video(instance.video_file.path)
"""
# With Django RQ Worker (My server is too slow for it)
if created:
queue = django_rq.get_queue("default", autocommit=True)
Create thumbnail
queue.enqueue(create_thumbnails, instance, instance.id)
Convert video
for resolution in ["480", "720", "1080"]:
#queue.enqueue(convert_video_to_hls, instance.video_file.path, resolution, #instance.id)
Delete the original video file
queue.enqueue(delete_original_video, instance.video_file.path) queue.enqueue(delete_original_video, instance.video_file.path)
"""
@receiver(post_delete, sender=Video) @receiver(post_delete, sender=Video)
def auto_delete_file_on_delete(sender, instance, **kwargs): def auto_delete_file_on_delete(sender, instance, **kwargs):
""" """