迭代器
编辑迭代器
编辑PHP客户端包含用于按页或按命中结果迭代的助手。
搜索响应迭代器
编辑使用SearchResponseIterator
通过 分页 按页迭代搜索结果。
这是一个示例
use Elastic\Elasticsearch\Helper\Iterators\SearchResponseIterator; $search_params = [ 'scroll' => '5m', // period to retain the search context 'index' => '<name of index>', // here the index name 'size' => 100, // 100 results per page 'body' => [ 'query' => [ 'match_all' => new StdClass // {} in JSON ] ] ]; // $client is Elasticsearch\Client instance $pages = new SearchResponseIterator($client, $search_params); // Sample usage of iterating over page results foreach($pages as $page) { // do something with hit e.g. copy its data to another index // e.g. prints the number of document per page (100) echo count($page['hits']['hits']), PHP_EOL; }
搜索命中迭代器
编辑使用SearchHitIterator
迭代SearchResponseIterator
,无需担心分页。
这是一个示例
use Elastic\Elasticsearch\Helper\Iterators\SearchHitIterator; use Elastic\Elasticsearch\Helper\Iterators\SearchResponseIterator; $search_params = [ 'scroll' => '5m', // period to retain the search context 'index' => '<name of index>', // here the index name 'size' => 100, // 100 results per page 'body' => [ 'query' => [ 'match_all' => new StdClass // {} in JSON ] ] ]; // $client is Elasticsearch\Client instance $pages = new SearchResponseIterator($client, $search_params); $hits = new SearchHitIterator($pages); // Sample usage of iterating over hits foreach($hits as $hit) { // do something with hit e.g. write to CSV, update a database, etc // e.g. prints the document id echo $hit['_id'], PHP_EOL; }