easy-swoole / elasticsearch Goto Github PK

    if (isset($type)) {  
        return "/$index/$type/$id/_create";
    }
    return "/$index/_create/$id";
}

    $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));