我有一个令人沮丧的elasticsearch问题,我试图更新一个索引。无论我尝试什么,只要返回“坏请求”(下面的堆栈),而更新与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发布于 2015-01-20 01:28:40
我认为:
$u['body']应:
$u['body']['doc']至少根据github的文件:
更新文档 让我们更新一个已编入索引的文档: $updateParams'index‘= 'my_index';$updateParams'type’= 'my_type';$updateParams'id‘= 'my_id';$updateParams’‘body’= array('my_key‘=> 'new_value');$retUpdate = $client->update($updateParams);
https://stackoverflow.com/questions/28034472
复制相似问题