Open
Description
代码如下:
$config = new \EasySwoole\ElasticSearch\Config([
'host' => 'es01',
'port' => 9200,
'username' => 'elastic',
'password' => 'xxxxxxxxx',
'scheme' => 'https'
]);
$elasticsearch = new \EasySwoole\ElasticSearch\ElasticSearch($config);
go(function () use ($elasticsearch) {
$bean = new \EasySwoole\ElasticSearch\RequestBean\Bulk();
$bean->setIndex('log_web');
//$bean->setType('log');
$body = [];
for ($i = 1; $i <= 5; $i++) {
$body[] = [
'create' => [
'_index' => 'my-index',
'_type' => 'my-type',
'_id' => $i * 1000
]
];
$body[] = [
'test-field' => 'test-data',
];
}
$bean->setBody($body);
$response = $elasticsearch->client()->bulk($bean)->getBody();
var_dump(json_decode($response, true));
Metadata
Metadata
Assignees
Labels
No labels