Laravel 5.2：使用Laravel Queues服务处理数据库插入-Java 学习之路

早上好！

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

$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次的作业 .

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表时，我可以在表中看到1700行 . 我尝试记录句柄功能但是当我运行 php artisan queue:listen 或_1129381时没有任何反应 . failed_jobs表也没有任何记录 .

句柄功能没有被执行，因此我无法记录内部发生的任何事情 . 我尝试用互联网上的例子来查找信息，但我能找到的只是一些我不需要的邮件示例 .

任何帮助将不胜感激！

1 回答

2

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

回复于 2024-05-06T04:25:07+08:00

Laravel 5.2：使用Laravel Queues服务处理数据库插入

1 回答

相关问题