Elasticsearch-PHP 更新返回错误请求，而 curl 不会返回 - elasticsearch-php update returns bad request where curl does not

elasticsearch-php update returns bad request where curl does not

我有一个令人沮丧的弹性搜索问题，我试图更新索引。无论我尝试什么，它只会返回"错误请求"（下面的堆栈），而更新适用于 cURL。我尝试将$u['body']作为JSON和数组进行更新调用。

这工作正常：

curl -XPOST 'http://localhost:9200/my_index/twitter/555805761389867009/_update' -d '{"doc": {"_located":"1","country_code":"IL"}}'

这段代码，无论如何：

<?php
  require 'vendor/autoload.php';
  require 'db.php';
  $q = "SELECT * FROM countries";
  $res = mysql_query($q) or die(mysql_error());
  while($row = mysql_fetch_array($res)) {
    $find[] = "/.*?".$row['c_name'].".*?/imUs";
    $replace[] = $row['c_short'];
  }
  $client = new Elasticsearch'Client();
  $tmp['index'] = "my_index";
  $tmp['type'] = "twitter";
  $tmp['body']['query']['match']['_located'] = 0;
  $tmp['fields'] = 'text';
  $tmp['size'] = 100;
  $store = $client->search($tmp);
  foreach($store['hits']['hits'] as $field) {
    if($m = preg_replace($find,$replace,$field['fields']['text'][0])) {
      if(strlen($m)==2) {
        unset($u);
        $u['index'] = 'my_index';
        $u['type'] = 'twitter';
        $u['id'] = $field['_id'];
        $u['body'] = json_encode(array('_located'=>"1", "country_code"=>$m));
        print_r($u);
        $client->update($u);
        die();
      }
    }
  }
?>

Array
(
    [index] => my_index
    [type] => twitter
    [id] => 555805761389867009
    [body] => {"_located":"1","country_code":"IL"}
)
PHP Fatal error:  Uncaught exception 'Guzzle'Http'Exception'ClientErrorResponseException' with message 'Client error response
[status code] 400
[reason phrase] Bad Request
[url] http://localhost:9200/my_index/twitter/555805761389867009/_update' in /home/martin/el-test/elasticsearch-php/vendor/guzzle/http/Guzzle/Http/Exception/BadResponseException.php:43
Stack trace:
#0 /home/martin/el-test/elasticsearch-php/vendor/guzzle/http/Guzzle/Http/Message/Request.php(145): Guzzle'Http'Exception'BadResponseException::factory(Object(Guzzle'Http'Message'EntityEnclosingRequest), Object(Guzzle'Http'Message'Response))
#1 [internal function]: Guzzle'Http'Message'Request::onRequestError(Object(Guzzle'Common'Event), 'request.error', Object(Symfony'Component'EventDispatcher'EventDispatcher))
#2 /home/martin/el-test/elasticsearch-php/vendor/symfony/event-dispatcher/Symfony/Component/EventDispatcher/EventDispatcher.php(164): call_user_func(Array, Object(Guzzle'Common'Event), 'request.error', Object(Symfony'Component'EventDispatcher'EventDispatcher))
#3  in /home/martin/el-test/elasticsearch-php/src/Elasticsearch/Connections/GuzzleConnection.php on line 271

我相信：

 $u['body']

应该是：

$u['body']['doc']

至少根据 github 中的文档：

更新文档

让我们更新一个已编制索引的文档：

$updateParams['index']          = 'my_index';
$updateParams['type']           = 'my_type';
$updateParams['id']             = 'my_id';
$updateParams['body']['doc']    = array('my_key' => 'new_value');
$retUpdate = $client->update($updateParams);

https://github.com/elasticsearch/elasticsearch-php