php - Laravel 5.2 队列和作业 - 不推送到作业数据库

Question

编辑 2:

以下是我们正在经历的步骤:

1. 运行计划(为每个公司创建 CollectHistoricalData 作业)
2. CollectHistoricalData 应该被推送到 Queue(jobs 表)
3. CollectHistoricalData 有一个函数 ApiDaemon::GetCompanyWithQuery($company, $query) 是从一个单独的类运行的，这个类也在其他几个地方被引用。
4. 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 个类是最容易的进入乔布斯。

长话短说

我们有一个计划，应该将引用另一个类中的函数的作业推送到作业表，但实际上是一个接一个地缓慢运行它们。这是什么原因造成的？

Answer 1

嗯...我很笨....

php artisan config:clear

我没有清除配置的缓存....哇...