Laravel 5.2：使用 Laravel 队列服务处理数据库插入答案

【问题标题】：Laravel 5.2: Handling database insertions using the Laravel Queues serviceLaravel 5.2：使用 Laravel 队列服务处理数据库插入
【发布时间】：2016-08-18 09:04:14
【问题描述】：

早上好！

我的控制器中有以下代码：

$num_rows = $this->drupalRequestRowCount();
$uris = $this->drupalRequestPrepareUri($num_rows, config('constants.IMPORT_DATA_URI'));
$requestHandler = new RequestHandler($uris[0]);
$content = $requestHandler->httpRequest();

// Dispatch each URI for the job that will handle
// the insertion of our Drupal data.
foreach($uris as $uri) {
  $job = (new DataJob($uri))->onQueue('data_export_insert');
  $this->dispatch($job);
}

return 'Jobs dispatched';

我有一个 Drupal 数据库，其中包含我希望每晚与我的 Laravel 数据库同步的数据。我使用了自己在 Drupal 中开发的 API，它返回了我的 Laravel 数据库所需的大量数据。

API 最多返回 10 个项目（其中包含大量数据）。 Drupal 数据库有我每晚需要导入的 +- 17000 个项目。我认为 Queue API 可能是一个很好的解决方案，可以批量导入数据，而不是一次全部导入。我在 foreach 循环中循环遍历 $uris 数组，该数组根据我得到的 $num_rows 将偏移量附加到 API。

因此，如果$num_rows 返回 17000 个项目，$uris 数组将包含 1700 个项目，如下所示：

[0] => 'http://mywebsite.com/api/request_data.json?offset=0'

[1] => 'http://mywebsite.com/api/request_data.json?offset=10'

[2] => 'http://mywebsite.com/api/request_data.json?offset=20' 等

这意味着一旦我运行 php artisan queue:listen database 命令，Laravel 将为我分派 1700 个作业。

以下代码是我要执行1700次的Job。

public function __construct($uri)
{
  $this->uri = $uri;
}
public function handle()
{
  try {
    Log::info('Inserting data into database for uri: ' . $this->uri);

    $requestHandler = new RequestHandler($this->uri);
    $content = $requestHandler->httpRequest();

    foreach($content as $key => $value) {
      $id = $value->id;
      $name = $value->name;
      DB::insert('INSERT INTO table_1 (id, name) VALUES (?, ?)', [$id, $name]);
    }
  } catch(\Exception $e) {
    Log::error('Error in job: '. $e->getMessage());
  }
}

我的问题是作业根本没有被执行。作业被正确分派到数据库，因为当我检查数据库中的 Jobs 表时，我可以在 Jobs 表中看到 1700 行。我尝试记录句柄函数，但是当我运行 php artisan queue:listen 或 php artisan queue:work 时没有任何反应。 failed_jobs 表也没有任何记录。

句柄函数没有被执行，所以我无法记录里面发生的任何事情。我尝试通过示例在互联网上查找信息，但我只能找到一些我不需要的邮件示例。

任何帮助将不胜感激！

【问题讨论】：

标签： database queue laravel-5.2 sql-insert

【解决方案1】：

解决了这个问题。确保您输入您的工作代码protected $payload！有效负载是您要传递给队列处理程序的数据！

【讨论】：