laravel - 如何从 laravel 作业运行有限数量的后台进程?
问题描述
我想从 laravel 作业中运行 ffmpeg 进程,但一次不要太多。我似乎无法做到正确。无论我为 $process_limit 设置什么 - 它一次只运行一个,并且中间有很长的延迟。也许我使用 public $timeout 错误。也许 retryUntil()。我不知道。
<?php
namespace FuquIo\LaravelFfmpeg;
use Cocur\BackgroundProcess\BackgroundProcess;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
class RenderMpeg4ToWebmJob implements ShouldQueue{
use Dispatchable, InteractsWithQueue, Queueable;
public $timeout = 3600;
/**
* @var string
*/
private $input_file;
/**
* @var array
*/
private $map;
/**
* Create a new job instance.
*
* @param array $map
* @param string $input_file
*/
public function __construct(array $map, string $input_file){
//
$this->map = $map;
$this->input_file = $input_file;
}
/**
* Execute the job.
*
* @return void
* @throws \Exception
*/
public function handle(){
$almost_timeout = $this->timeout - 100;
$map = $this->map;
$input_file = $this->input_file;
$cmds = '(' . implode('; ', config('fuqu-ffmpeg.command')) . ')';
$cmds = str_replace(array_keys($map), array_values($map), $cmds);
Log::debug($cmds);
$process_limit = config(ServiceProvider::SHORT_NAME .'.process_limit');
Redis::funnel('ffmpeg')->limit($process_limit)->then(
function () use ($cmds, $input_file, $almost_timeout){
$process = new BackgroundProcess($cmds);
$process->run();
if(!$process->isRunning()){
throw new \Exception('Unable to execute file processing command on ' . $input_file);
}
/**
* This doesn't prevent an additional
* background process from spawning
* but it does give a head start
*/
$slept = 0;
do{
sleep(10);
$slept += 10;
}while($process->isRunning() and ($slept < $almost_timeout));
}, function (){
// Could not obtain lock...
return $this->release(100);
});
}
/**
* Rather than doing x tries,
* just keep trying until.
*
* @return \DateTime
*/
public function retryUntil(){
return now()->addDays(1);
}
}
解决方案
事实证明问题中的代码确实有效。我的问题在 bg 过程中。以数字结尾的文件有问题。我想我会留下代码......可能对某人有用。
推荐阅读
- azure - 如何使用 Azure.Identity.ClientSecretCredential 访问 Azure 队列?
- javascript - 跨分片 discord.js 对表情符号做出反应
- kotlin - 阻止泛型在 Kotlin 中推断任何类型
- java - NoSuchFieldException:驱动程序
- kotlin - 如何降低攀登排行榜的代码复杂度?
- apache-kafka - org.apache.kafka.clients.consumer.Consumer.poll 长时间阻塞
- google-chrome - 运行 Protractor 测试时 ChromeDriver 和 Chrome 之间的版本不匹配,但没有可用的更新
- node.js - MongoDB,如何在 $lookup 解析的字段上使用 $geoNear
- javascript - 在 reactJs 中将对象添加到我的购物车中的数组
- oracle - NiFi 数据库连接池无法正常工作