php - 如何在 Guzzle 中获取 Request 对象？

Question

我需要使用 Guzzle 检查数据库中的很多项目。例如，项目数量为 2000-5000。它太多了，无法将其全部加载到一个数组中，因此我想将其分成 block :SELECT * FROM items LIMIT 100。当最后一个项目发送到 Guzzle 时，将请求接下来的 100 个项目。在“已完成”处理程序中，我应该知道哪个项目得到了响应。我看到我们这里有 $index，它指向当前项目的编号。但是我无权访问 $items 变量可见的范围。无论如何，如果我什至通过 use($items) 访问它，那么在循环的第二遍中我得到错误的索引，因为 $items 数组中的索引将从 0 开始，而 $index 将 >100。所以，这个方法是行不通的。

    $client = new Client();
    $iterator = function() {
         while($items = getSomeItemsFromDb(100)) {
              foreach($items as $item) {
                   echo "Start item #{$item['id']}";
                   yield new Request('GET', $item['url']);
              }
         }
    };

    $pool = new Pool($client, $iterator(), [
        'concurrency' => 20,
        'fulfilled' => function (ResponseInterface $response, $index) {
            // how to get $item['id'] here?
        },
        'rejected' => function (RequestException $reason, $index) {
            call_user_func($this->error_handler, $reason, $index);
        }
    ]);

    $promise = $pool->promise();
    $promise->wait();

我想如果我可以做类似的事情

$request = new Request('GET', $item['url']);
$request->item = $item;

然后在“已完成”处理程序中从 $response 获取 $request - 这将是理想的。但正如我所见，没有办法做类似 $response->getRequest() 的事情。关于如何解决这个问题有什么建议吗？

Answer 1

遗憾的是，在 Guzzle 中无法获取请求。有关详细信息，请参阅响应创建。

但是你可以只返回一个不同的 promise 并使用 each_limit() 而不是 Pool (在内部，池类只是 EachPromise 的包装器>).它是更通用的解决方案，适用于任何类型的 promise 。

另请查看 another example of EachPromise usage for concurrent HTTP request .

$client = new Client();
$iterator = function () use ($client) {
    while ($items = getSomeItemsFromDb(100)) {
        foreach ($items as $item) {
            echo "Start item #{$item['id']}";
            yield $client
                ->sendAsync(new Request('GET', $item['url']))
                ->then(function (ResponseInterface $response) use ($item) {
                    return [$item['id'], $response];
                });
        }
    }
};

$promise = \GuzzleHttp\Promise\each_limit(
    $iterator(),
    20,
    function ($result, $index) {
        list($itemId, $response) = $result;

        // ...
    },
    function (RequestException $reason, $index) {
        call_user_func($this->error_handler, $reason, $index);
    }
);

$promise->wait();