2

所以我使用 Guzzle 6 进行不确定的并发 api 调用，但我想做的一件事是跟踪 promise 当前正在处理的数组值，因为我最初是根据数据库查询结果处理 api 调用。之后，我想用我从 api 得到的任何东西将值更新回数据库。

use GuzzleHttp\Pool;
use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;

$client = new Client();

$requests = function () {
    $uri = 'http://127.0.0.1:8126/guzzle-server/perf';
    foreach($database_result as $res) {

        /*the res array contains 
        ['id' => 'db id', 'query' => 'get query array'];
        */

        $url = $uri . '?' . http_build_query($res['query']);

        yield new Request('GET', $url);
    }
};

$pool = new Pool($client, $requests(), [
    'concurrency' => 5,
    'fulfilled' => function ($response, $index) {
        /**
         * HERE i want to be able to somehow 
         * retrieve the current responses db id
         * this way I can obviously update anything 
         * i want on the db side
         */
    },
    'rejected' => function ($reason, $index) {
        /**
         * HERE i want to be able to somehow 
         * retrieve the current responses db id
         * this way I can obviously update anything 
         * i want on the db side
         */
    },
]);

// Initiate the transfers and create a promise
$promise = $pool->promise();

// Force the pool of requests to complete.
$promise->wait();
...

对此的任何帮助将是惊人的。我想就如何最好地处理这种情况获得建议。我宁愿以一种聪明、合乎逻辑的方式来做这件事。

谢谢您的帮助

4

1 回答 1

2

所以我想通了。

基本上

    $requests = function () {
    $uri = 'http://127.0.0.1:8126/guzzle-server/perf';
    foreach($database_result as $key => $res) {

        /*the res array was updated to be  
        ['id' => 'get query array'];
        */

        $url = $uri . '?' . http_build_query($res);

        //here is the key difference in change
        yield $key => new Request('GET', $url);
    }
};

现在稍后池功能中的索引将包含您想要的索引。

希望这可以帮助。

参考：https ://github.com/guzzle/guzzle/pull/1203

于 2016-07-28T21:54:41.093 回答