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

2019-11-11 16:30:17 阅读：479 来源： 互联网

标签：guzzle php

我需要使用Guzzle检查数据库中的很多项目.例如,项目数量为2000-5000.将其全部加载到单个数组中太多了,因此我想将其分成多个块：SELECT * FROM items LIMIT100.当最后一个项目发送到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()的事情.
关于如何解决这个问题的任何建议？

解决方法:

不幸的是,在Guzzle中不可能收到请求.有关更多详细信息,请参见响应创建.

但是,您可以返回一个不同的Promise,并使用each_limit()代替Pool(内部,pool类只是对EachPromise的包装).这是更通用的解决方案,可与任何类型的诺言一起使用.

另外看看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();

标签：guzzle,php
来源： https://codeday.me/bug/20191111/2021098.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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