ビデオの処理は、ウェブアプリケーションが処理できる最も重いタスクの1つです。 コントローラの内部では、PHP-FPM トレードをブロックし、ユーザーを不満に陥れ、タイムアウトを危険にさらしている可能性があります。 shell_exec(‘ffmpeg …’) 2026年、我々はそうしません。我々はビデオ処理を で、 . asynchronous distributed pipeline Symfony 7.4 のリリースで、私たちはこれを強力でネイティブにする新しいツールを持っています。 で、 そして、The パラレルパイプラインを構築する。 edicated #[Video] validation constraint native support for shared directories, mature Messenger component この記事では、以下のような生産レベルのビデオ処理アーキテクチャを構築します。 
 
 
 
 Validates は、新しい Symfony 7.4 制限を使用して即座にアップロードします。 バックグラウンドの労働者に重荷をかけます。 同時にタスク(トランスコード、マイナス画像、分析)を並行する。 前提条件 
 
 
 
 
 PHP 8.2+ (PHP 8.4 推奨) Symfony 7.4 (symfony/skeleton & symfony/webapp-pack) あなたのサーバー/コンテナにインストールされた FFmpeg (sudo apt install ffmpeg) コンポーネーターパッケージ:php-ffmpeg/php-ffmpeg(v1.3+)symfony/messenger\symfony/validator The Architecture: Shared Directory 戦略 ユーザーがビデオを Web コンテナにアップロードする場合、Working Container (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) (Working Container) シンフォニア7・4では、私たちは「 ” パターン – ノード間で共有されるステータスデータの標準化された場所(NFS マウントや Docker ボリュームなど)。 Shared Directory Infrastructure setup (Conceptual): 
 
 
 Web ノード: /mnt/shared_storage を ./var/storage にマウントします。 Worker Node: 同じボリュームを ./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%'
 認証:The 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 binary は Web ユーザーによって実行可能である必要があります。 オリジナルタイトル: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
    ) {}
}
 輸送コンフィギュレーション 少なくとも2つの交通手段が必要です。 
 
 
 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
 処理の論理 We will use the まず、図書館をインストールする: 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");
    }
}
 The Controller: 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);
    }
}
 パイプラインを走る このパラレリズムをアクションで見るには、従業員を動かす必要があります。生産環境(KubernetesやDocker Swarmのような)では、これらの展開を独立してスケールします。 ディスパッキングとミニマルを扱う。 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
 検証 
 
 
 
 
 50MB MP4 ファイルを /api/videos/upload にアップロードします。 Observe Terminal 1: It receives ProcessVideoUpload, then almost instantly dispatches 5 new messages (3 thumbnails, 2 transcodes). It then processes the thumbnails. それから、ほぼ瞬時に5つの新しいメッセージを送信します。 Observe Terminal 2: It picks up TranscodeVideo. You will see the CPU usage rise as FFmpeg runs. あなたはFFmpegを実行するときにCPUの使用量の増加を見るでしょう。 あなたの ./var/storage/processed/ ディレクトリをチェックしてください. あなたはすぐに小さな画像が表示され、後にトランスコードされたビデオファイルが続きます。 結論 Symfony 7.4 を活用することで、複雑な問題をクリーンで管理可能なアーキテクチャに変えました。 
 
 
 
 信頼性: # [ビデオ] 制限は、無効なファイルが私たちのパイプラインに入らないことを保証します。 スケーラビリティ: async_priority と async_heavy を分離することにより、大規模なビデオエンコーディングによって小型画像の生成がブロックされることはありません。 トランスコード ライブラリまたはストレージ エンジン(例えば Flysystem を使用して S3 に)を変更できます。 このアーキテクチャは「生産準備完了」ですが、成長を可能にします。 ワン (league/flysystem-aws-s3-v3を使用しますが、メッセンジャーパイプラインのコンセプトはまったく同じです。 Shared Directory Object Storage abstraction 正しい制約と列のアーキテクチャで、それは予測可能で観察可能になります。 シンフォニーパイプラインのスケーリングについて質問がありますか? 接続しましょう. 私は現代のPHPアーキテクチャに関する日々のヒントを共有します。 Linkedin: Connect With Me(リンク) ] 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

このオーディオは、ストーリーの元の言語で制作されています。

ビデオをスケールする方法:並行処理、メッセンジャー、その他

About Author

コメント

ラベル

この記事は

Related Stories

タップして稼ぐ：テレグラムはソラナより先に次の100億人の暗号通貨ユーザーを獲得する可能性がある

HackerNoon Coded: HackerNoonが最も活発に活動している上位10カ国

ユーザー中心の暗号通貨製品の作成: 顧客からのフィードバックの重要性

Claude Sonnet 3.5 システムプロンプトの漏洩: 法医学的分析

タップして稼ぐ：テレグラムはソラナより先に次の100億人の暗号通貨ユーザーを獲得する可能性がある

HackerNoon Coded: HackerNoonが最も活発に活動している上位10カ国

ユーザー中心の暗号通貨製品の作成: 顧客からのフィードバックの重要性

Claude Sonnet 3.5 システムプロンプトの漏洩: 法医学的分析

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps