ElasticSearch + Go：索引失败（名称无功能）

Question

我正在尝试使用 v1.4x 中的完成建议器让 ElasticSearch 为我的自动完成服务索引内容。我正在听从ElasticSearch 的建议- 你完成我并且正在使用 Go Client Olivere/elastic。我的索引方法看起来有点像这样：func IndexVehicle(client *elastic.Client, vehicle Vehicle) (bool, error) {    // See if it exists already    fetch, err := client.Get().        Index(vehicleIndex).        Type("vehicle").        Id(vehicle.Id).        Do()    if err != nil || fetch.Found {        return false, err    }    vehicleName := fmt.Sprintf("%s %s (%s) %s", vehicle.Make, vehicle.Model, vehicle.Model_year, vehicle.Primary_fuel)    suggest := elastic.NewSuggestField()    suggest.Input(vehicle.Make, vehicle.Model, vehicle.Primary_fuel, vehicle.Model_year).        Output(vehicleName).        Payload(vehicle)    // Go forth and save    put, err := client.Index().        Index(vehicleIndex).        Type("vehicle").        Id(vehicle.Id).        Debug(true).Pretty(true).        BodyJson(indexBody{Name: vehicleName, Suggest: suggest}).        Do()    if err != nil {        return false, err    }    return put.Created, nil}现在奇怪的是，在我的一些测试中，这种方法工作正常，项目将被索引。在擦除和重建索引后的其他测试中，测试将失败：早期的测试在调试中看起来像这样：2014/12/15 14:11:37 PUT /vehicle/vehicle/369f96459b340507c4688740da3bfe1a?pretty=true HTTP/1.1Host: localhost:9200User-Agent: elastic/1.3.1 (darwin-amd64)Transfer-Encoding: chunkedAccept: application/jsonContent-Type: application/jsonAccept-Encoding: gzip{"name":"American Motors Corporation Eagle 4WD (1986) regular","suggest":{"input":["American Motors Corporation","Eagle 4WD","regular","1986"],"output":"American Motors Corporation Eagle 4WD (1986) regular","payload":{"make":"American Motors Corporation","model_year":"1986","model":"Eagle 4WD","primary_fuel":"regular","vehicle_class":"Special Purpose Vehicle 4WD","transmission":"Automatic 3-spd","displacement":"4.2","drive":"4-Wheel or All-Wheel Drive","city_mpg":"15.0","highway_mpg":"19.0","comb_mpg":"17.0"}}}2014/12/15 14:11:37 HTTP/1.1 201 CreatedContent-Length: 134Content-Type: application/json; charset=UTF-8

Answer 1

只是为了完整性：当我用“post”而不是“POST”初始化我的请求方法时，我遇到了同样的错误

像这样：

req, _ := http.NewRequest("post", url, query)

// returns: Error 400: ElasticsearchIllegalArgumentException[No feature for name [_bulk]]

req, _ := http.NewRequest("POST", url, query)

// works just fine

Answer 2

该异常仅在一个地方触发，即在 Get Index API 调用期间。这意味着您的车辆 ID 在此处必须为空：

fetch, err := client.Get().

        Index(vehicleIndex).

        Type("vehicle").

        Id(vehicle.Id).       //<-- this

        Do()

您正在尝试执行 Get Document API，它遵循GET /{index}/{type}/{id}. 但是，您的客户端不会区分 Get Document 和 Get Index API 调用……并且它不会验证您的参数是否为非空。

因此，如果将 nullvehicle.Id传递给 Get 方法，则您的最终 URL 实际上将是GET /{index}/{type}/

从 Elasticsearch 的角度来看，这不再是一个 Get Document API 调用……它实际上是一个 Get Index 调用，其格式如下： GET /{index}/{feature}. 特征可以是以下之一：_settings，_mappings，_aliases或_warmers。

因为vehicle不是这些特性之一，ES 正在抛出异常并喷涌而出。您可以从控制台验证这一点：

curl -XGET localhost:9200/my_index/vehicle/