为了限制来自队列的作业数量,我在PHP作业文件中引入了一些代码。推动工作后,我睡了一段时间:
// random nr between 3 and 4 min
$r = rand(180, 240);
sleep($r);
我正在使用的队列是一个SQS FIFO队列,提交的作业就好了。我的工作者只使用一个进程并尝试3次:
more aws-worker.conf
command=php /var/www/html/website/artisan queue:work sqs_aws --sleep=5 --tries=3
autostart=true
autorestart=true
user=root
numprocs=1
但是,当我提交2个作业时,队列工作者会在1分钟后释放它们,但不会在SQS上删除它们。所以他们仍然在飞行中,经过3次获得失败的标签:
[2018-12-23 13:21:54] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:22:56] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:27:55] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:29:01] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:34:00] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:35:06] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:40:05] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:40:05] Failed: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:41:10] Processing: App\Jobs\DispatchAwsGatewayJob
[2018-12-23 13:41:10] Failed: App\Jobs\DispatchAwsGatewayJob
其他一些队列细节:
Default Visibility Timeout: 30 seconds
Message Retention Period: 4 days
Receive Message Wait Time: 0 seconds
睡眠代码是否可能干扰fifo队列?我没有任何其他选项限制队列上的作业....
作业的默认超时为60秒。达到超时后,工作程序将被终止并且作业将返回队列,除非已达到最大尝试次数,在这种情况下作业将失败。
您可以在队列工作者级别或作业级别增加作业的超时。
如果要增加队列工作程序的超时,请在命令行上指定超时:
php artisan queue:work --timeout=300
如果要增加特定作业的超时,请在作业类上设置$timeout
属性:
public $timeout = 300;
然而,下一个问题是Default Visibility Timeout
。由于它仅设置为30秒,因此作业将再次在队列中可用,而另一个工作人员可以将其拾取并运行它。如果你只有一个工人,这不是什么大问题。但是,您现在想要修复它,以便以后在决定添加更多工作程序时不会遇到问题。
Default Visibility Timeout
应该高于您期望任何工作运行的最长时间。所以,如果$timeout
是300,那么Default Visibility Timeout
应该> 300。