编辑 2:
以下是我们正在经历的步骤:
- 运行计划(为每个公司创建
CollectHistoricalData
作业) CollectHistoricalData
应该被推送到 Queue(jobs
表)CollectHistoricalData
有一个函数ApiDaemon::GetCompanyWithQuery($company, $query)
是从一个单独的类运行的,这个类也在其他几个地方被引用。GetCompanyWithQuery
收集数据并将其插入数据库。
它一直运行正常,但挂起不是将作业插入作业表,而是同步运行,一个接一个。
编辑 1:
.env
文件设置为使用database
QUEUE_DRIVER
,我什至尝试在config/中对其进行硬编码queue.php
文件。
我们正在为一个项目使用 Laravel 5.2。在这个项目中,我们需要每小时 cURL 一个 url 并将数据保存到数据库中。我们最初使用的是 Cron Jobs,基本上在大约一分钟内触发了数千个 cURL,这会导致 PHP 因负载而崩溃。
我们决定转向 Laravel 的作业和队列,但没有成功。我们正在为我们的作业使用数据库驱动程序,并尝试了多种不同的方法将作业放入数据库,因此我们拥有的守护进程可以处理它们。
现在这是我们的代码,我们正在使用 Kernel.php $schedule
来启动这件事,所以我们不会有数百个请求试图在一个小时内发生,这会导致数以万计的 cURL。
Kernel.php 时间表:
$schedule
->call(function () {
$items = DB::select('{selecting certain things to run}');
foreach ($items as $q) {
$this->dispatch(new CollectHistoricalData(Company::find($q->company_id), ApiQuery::find($q->query_id)));
}
})
->hourly()
->name('Historical Pulls')
->withoutOverlapping()
->before(function() {
$this->startTime = Carbon::now();
})
->after(function () {
mail({mail us a report afterward});
});
当它运行时,它会坐在那里一个一个地运行它们,而不是将它们推送到创建的 Jobs 表中。
收集历史数据.php:
<?php
namespace App\Jobs;
use App\Helpers\Daemons\ApiDaemon;
use App\Jobs\Job;
use App\Models\Company;
use App\Models\ApiQuery;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
class CollectHistoricalData extends Job implements ShouldQueue
{
use InteractsWithQueue, SerializesModels;
protected $company, $query;
/**
* CollectHistoricalData constructor.
* @param Company $company
* @param ApiQuery $query
*/
public function __construct(Company $company, ApiQuery $query)
{
$this->company = $company;
$this->query = $query;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
mail({let us know what started and when});
QueryDaemon::GetCompanyWithQuery($this->company, $this->query);
}
public function failed()
{
mail({mail us letting us know it failed});
}
}
这项工作是引用另一个包含函数的类(因为该代码本身就是一头笨重的野兽),加上大约有 20 个这样的类,因此引用该类而不是重新创建所有 20 个类是最容易的进入乔布斯。
长话短说
我们有一个计划,应该将引用另一个类中的函数的作业推送到作业表,但实际上是一个接一个地缓慢运行它们。这是什么原因造成的?
最佳答案
嗯...我很笨....
php artisan config:clear
我没有清除配置的缓存....哇...
关于php - Laravel 5.2 队列和作业 - 不推送到作业数据库,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37734656/