Працэсар відэа з'яўляецца адным з найбольш цяжкіх задач вэб-прыкладання можа справіцца. Унутры кантролера, вы, вядома, блокуеце свае PHP-FPM трэды, раздражняючы вашых карыстальнікаў, і рызыкуючы timeouts. shell_exec(‘ffmpeg …’) У 2026 годзе мы не робім гэта. І . asynchronous distributed pipeline З выпуску Symfony 7.4, у нас ёсць новыя інструменты, якія робяць гэта стабільна і нацыянальна. І І на Выкарыстанне паралельных трубопроводаў. edicated #[Video] validation constraint native support for shared directories, mature Messenger component У гэтай артыкуле мы будзем будаваць архітэктуру апрацоўкі відэа ў ступені вытворчасці, якая: 
 
 
 
 Валідацыя загружаецца адразу, выкарыстоўваючы новыя абмежаванні Symfony 7.4. Загрузіць важныя грузы на фоне работнікаў. Паралелізуе задачы (транскадыванне, мініяцюры, аналіз) адразу. Перспектывы 
 
 
 
 
 PHP 8.2 + (PHP 8.4 рэкамендавана) Symfony 7.4 (Symfony / скелет & Symfony / Webapp-pack) FFmpeg усталяваны на вашым серверы/контейнер (sudo apt install ffmpeg). Пакеты кампазітара:php-ffmpeg/php-ffmpeg(v1.3+)symfony/messenger\symfony/validator Архітэктура: Сцягнутая каталогная стратегія У нашай багатай беларускай літаратуры няма другога такога твора, які па энцыклапедычнасці выяўлення ў ім нацыянальнага, так набліжаўся б да "Новай зямлі". У Symfony 7.4 мы схіляемся ў « Памер — стандартызаванае месца для дадзеных, якія размяшчаюцца на уздзеяннях (напрыклад, NFS-монты або Docker Volumes). Shared Directory Infrastructure setup (Conceptual): 
 
 
 Web Node: Маятніцы /mnt/shared_storage да ./var/storage. Рабочая вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная вучэбная. Мы ўбачым гэты шлях у Для таго, каб гарантаваць наш код агностичны фізічнага месцазнаходжання. services.yaml # config/services.yaml
parameters:
    # The absolute path to the shared storage (mapped volume)
    app.storage_dir: '%kernel.project_dir%/var/storage'

services:
    _defaults:
        autowire: true
        autoconfigure: true
        bind:
            $storageDir: '%app.storage_dir%'
 Вынікі пошуку - new #[video] Constraint У першых версіях мы павінны былі пакласціся на генералы. абмежаваць і гаварыць тыпы MIME, або напісаць складаныя наладныя валідатары, каб праверыць працягласць і кодэкі. File Symfony 7.4 прадстаўляе родную мову Выкарыстоўвайце — выкарыстоўвайце Інтэрнэт (via Для таго, каб ацаніць метаданныя, перш чым вы нават прыняць бізнес-логіку. #[Video] FFmpeg ffprobe Давайце створым DTO для нашага загрузкі. // src/Dto/VideoUploadDto.php
namespace App\Dto;

use Symfony\Component\HttpFoundation\File\UploadedFile;
use Symfony\Component\Validator\Constraints as Assert;

final readonly class VideoUploadDto
{
    public function __construct(
        #[Assert\NotBlank]
        #[Assert\Video(
            maxSize: '500M',
            mimeTypes: ['video/mp4', 'video/quicktime', 'video/webm'],
            minWidth: 1280,
            maxWidth: 3840, // 4K limit
            minDuration: 5, // Seconds
            maxDuration: 3600,
            allowPortrait: false, // Enforce landscape
            suggestedExtensions: ['mp4', 'mov']
        )]
        public UploadedFile $file,

        #[Assert\NotBlank]
        #[Assert\Length(min: 5, max: 255)]
        public string $title
    ) {}
}
 Гэта абмежаванне патрабуе, каб ffprobe бінарны быць выканаўчым для вэб-карыстальніка. Альтэрнатыўныя назвы: Messenger Pipelines Для забеспячэння работы мікра-ГЭС, водны струмень мусіць быць штучна створаны, але створаны штучна. Наступныя дакументы (DTOs) Мы выкарыстоўваем класы readonly для незмінных аб'ектаў паведамленняў. // src/Message/ProcessVideoUpload.php
namespace App\Message;

/**
 * The Trigger: Dispatched immediately after upload.
 */
final readonly class ProcessVideoUpload
{
    public function __construct(
        public string $videoId,
        public string $filename
    ) {}
}
 // src/Message/TranscodeVideo.php
namespace App\Message;

/**
 * Sub-Task: Heavy encoding work.
 */
final readonly class TranscodeVideo
{
    public function __construct(
        public string $videoId,
        public string $filename,
        public string $targetFormat // e.g., 'hls', 'mp4-720p'
    ) {}
}
 // src/Message/GenerateThumbnail.php
namespace App\Message;

/**
 * Sub-Task: Image extraction.
 */
final readonly class GenerateThumbnail
{
    public function __construct(
        public string $videoId,
        public string $filename,
        public int $timestamp
    ) {}
}
 Конфігурацыя транспорта Нам патрэбны як мінімум два транспарты: 
 
 
 async_priority: для хуткага задання (маленькія малюнкі, абнаўлення базы дадзеных). async_heavy: Для доўгіх заданняў (транскадыроўкі). Гэта перашкоджае 10-мінутным 4K-кодам ад блокавання генерацыі мініяцюрных малюнкаў. # config/packages/messenger.yaml
framework:
    messenger:
        failure_transport: failed

        transports:
            # Fast lane
            async_priority:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: priority_queue

            # Slow lane (Heavy video processing)
            async_heavy:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: video_encoding_queue
                    # Increase timeout for workers on this queue
                    auto_setup: true

            failed: 'doctrine://default?queue_name=failed'

        routing:
            'App\Message\ProcessVideoUpload': async_priority
            'App\Message\GenerateThumbnail': async_priority
            'App\Message\TranscodeVideo': async_heavy
 Логіка працэсу Мы будзем выкарыстоўваць Першае, што трэба зрабіць, гэта усталяваць: php-ffmpeg composer require php-ffmpeg/php-ffmpeg
 Менеджэр Handler Гэта рэпрэсіўны рэпрэсіўны механізм, які працуе на дыктатуру. - Гэта рэпрэсіўны механізм, які працуе на дыктатуру. // src/MessageHandler/ProcessVideoUploadHandler.php
namespace App\MessageHandler;

use App\Message\GenerateThumbnail;
use App\Message\ProcessVideoUpload;
use App\Message\TranscodeVideo;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
use Symfony\Component\Messenger\MessageBusInterface;

#[AsMessageHandler]
final readonly class ProcessVideoUploadHandler
{
    public function __construct(
        private MessageBusInterface $bus,
        private LoggerInterface $logger
    ) {}

    public function __invoke(ProcessVideoUpload $message): void
    {
        $this->logger->info("Starting pipeline for video: {$message->videoId}");

        // 1. Dispatch Thumbnail Generation (Fast)
        // We generate 3 thumbnails in parallel by dispatching 3 messages
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 5));
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 30));
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 60));

        // 2. Dispatch Transcoding (Slow/Heavy)
        // These will go to the 'async_heavy' transport
        $this->bus->dispatch(new TranscodeVideo($message->videoId, $message->filename, 'mp4-720p'));
        $this->bus->dispatch(new TranscodeVideo($message->videoId, $message->filename, 'webm-720p'));

        $this->logger->info("Pipeline dispatched successfully.");
    }
}
 Вынікі пошуку - heavy worker handler Зараз мы выкарыстоўваем сапраўдную логіку, выкарыстоўваючы . FFmpeg // src/MessageHandler/TranscodeVideoHandler.php
namespace App\MessageHandler;

use App\Message\TranscodeVideo;
use FFMpeg\FFMpeg;
use FFMpeg\Format\Video\X264;
use Psr\Log\LoggerInterface;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
final readonly class TranscodeVideoHandler
{
    public function __construct(
        private string $storageDir,
        private LoggerInterface $logger,
    ) {}

    public function __invoke(TranscodeVideo $message): void
    {
        $inputFile = $this->storageDir . '/' . $message->filename;
        $outputFile = $this->storageDir . '/processed/' . $message->videoId . '-' . $message->targetFormat . '.mp4';

        // 1. Verify existence (Robustness)
        if (!file_exists($inputFile)) {
            // In a shared dir setup, there might be a slight sync delay or error.
            // Throwing exception triggers Messenger retry policy.
            throw new \RuntimeException("File not found: $inputFile");
        }

        $this->logger->info("Transcoding {$message->videoId} to {$message->targetFormat}...");

        // 2. Initialize FFMpeg
        $ffmpeg = FFMpeg::create();
        $video = $ffmpeg->open($inputFile);

        // 3. Configure Format (x264 codec, AAC audio)
        $format = new X264();
        $format->setKiloBitrate(1000)
               ->setAudioChannels(2)
               ->setAudioKiloBitrate(128);

        // 4. Save
        // This is a blocking process that can take minutes.
        // Because it's in a worker, the user is not waiting.
        $filesystem = new Filesystem();
        $filesystem->mkdir(dirname($outputFile));
        
        $video->save($format, $outputFile);

        $this->logger->info("Transcoding complete: $outputFile");
    }
}
 Вынікі пошуку - Binding It Together Задача контролера зараз неверагодна простая: Validate -> Move to Storage -> Dispatch -> Return 202 Accepted. // src/Controller/VideoController.php
namespace App\Controller;

use App\Dto\VideoUploadDto;
use App\Message\ProcessVideoUpload;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Attribute\MapUploadedFile;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Routing\Attribute\Route;
use Symfony\Component\Uid\Uuid;

#[Route('/api/videos')]
class VideoController extends AbstractController
{
    public function __construct(
        private string $storageDir,
        private MessageBusInterface $bus
    ) {}

    #[Route('/upload', methods: ['POST'])]
    public function upload(
        // Validates automatically using our DTO constraints
        #[MapUploadedFile] VideoUploadDto $uploadDto
    ): JsonResponse {
        
        $file = $uploadDto->file;
        $videoId = Uuid::v7()->toRfc4122();
        
        // 1. Move file to Shared Directory
        // We use the ID as the filename to avoid collisions
        $filename = $videoId . '.' . $file->guessExtension();
        $file->move($this->storageDir, $filename);

        // 2. Dispatch the Manager Message
        $this->bus->dispatch(new ProcessVideoUpload($videoId, $filename));

        // 3. Immediate Response
        return $this->json([
            'status' => 'processing',
            'id' => $videoId,
            'message' => 'Video accepted. Processing pipelines initiated.'
        ], 202);
    }
}
 Загрузіць трубопроводы Для забеспячэння работы мікра-ГЭС, водны струмень мусіць быць штучна створаны. Забяспечвае распрацоўку і мінімалізацыю. Terminal 1 (The Priority Worker): php bin/console messenger:consume async_priority -vv
 Вы можаце запусціць 4 або 5 з гэтых кантэйнераў. Terminal 2 (The Heavy Worker): php bin/console messenger:consume async_heavy -vv
 Праверка 
 
 
 
 
 50 Мб MP4 файла ў /api/videos/upload. Назіраць Термінал 1: Ён атрымлівае ProcessVideoUpload, а затым амаль адразу адпраўляе 5 новых паведамленняў (3 мініяцюры, 2 транскоды). Паглядзець Термінал 2: Ён выбірае TranscodeVideo. Вы будзеце бачыць выкарыстанне CPU ўзровень, як FFmpeg працуе. Праверыць ваш ./var/storage/processed/ каталог. Вы будзеце бачыць мініяцюры з'явіцца хутка, затым пазней перакладзеныя відэафайлы. Высновы Выкарыстоўваючы Symfony 7.4, мы трансфармавалі складаную праблему ў чыстую, кіраваную архітэктуру. 
 
 
 
 Вядомы: абмежаванне #[Video] забяспечвае, што ніякія невядомыя файлы ніколі не ўвайдуць у нашу трубку. Шкалавальнасць: адрозніваючы async_priority і async_heavy, генерацыя мініяцюрных малюнкаў ніколі не блокуецца вялікім відэа-кодаваннем. Вы можаце змяніць бібліятэку перакладанняў або рухавік захоўвання (напрыклад, на S3 з дапамогай Flysystem) без допыту кантролера або логікі валідацыі. Цяпер «дармаеды» павінны плаціць не ўніфікаваны падатак («збор»), а кампенсаваць дзяржаве затраты за нейкія паслугі. З а (з выкарыстаннем ліга / flysystem-aws-s3-v3), але канцэпты трубкі Messenger застаюцца точна такім жа. Shared Directory Object Storage abstraction Не варта думаць, што добры дом з такім памерам падмурка можа быць толькі двухпавярховы і з мансардай. Ці магу я сама без яго прыйсці да Вас на кансультацыю? з павагай да Вас. LinkedIn: Звяжыцеся са мной [ ] https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

This story contains AI-generated text. The author has used AI either for research, to generate outlines, or write the text itself. 

Read My Stories

Гэта аўдыя зроблена на мове арыгіналу гісторыі!

Як скараціць відэа: паралельная апрацоўка, Messenger і многае іншае

About Author

КАМЕНТАРЫІ

ВЕСІЦЬ БІРКІ

ГЭТЫ АРТЫКУЛ БЫЎ ПРАДСТАЎЛЕНЫ Ў

Related Stories

34 Stories To Learn About Eos

Zero-Knowledge, Zero Limits: The Vision Behind Aleo's New Blockchain Paradigm

How Edge & Node’s Rodrigo Coelho Is Reimagining the Web with The Graph

Tatiana: A Love Letter from HackerNoon's Best Crypto Journalist of 2021

34 Stories To Learn About Eos

Zero-Knowledge, Zero Limits: The Vision Behind Aleo's New Blockchain Paradigm

How Edge & Node’s Rodrigo Coelho Is Reimagining the Web with The Graph

Tatiana: A Love Letter from HackerNoon's Best Crypto Journalist of 2021

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps