在Elasticsearch中更新文檔時出錯

我正在嘗試更新Elasticsearch中的幾個文檔。我想要更新其映射類型很長的幾個字段的值。當前這些字段的值爲null。在Elasticsearch中更新文檔時出錯

的Python腳本：

def dump_random_values(): 

    query = {"size": 2000, "query": {"bool": {"must": [{"term": {"trip_client_id": {"value": 23}}}, {"type": {"value": "trip-details"}}]}}} 
    docs = es.search(index=analytics_index, doc_type="trip-details", body=query) 
    trips = docs["hits"]["hits"] 
    for trip in trips: 
     doc_id = trip["_id"] 

     trip["_source"]["vehicle_capacityInWeight"] = random.randint(40, 50) 
     trip["_source"]["shipment_packageWeight"] = random.randint(1, 39) 

     trip["_source"]["vehicle_capacityInVolume"] = random.randint(40, 50) 
     trip["_source"]["shipment_packageVolume"] = random.randint(1, 39) 

     trip["_source"]["shipment_packageUnits"] = random.randint(40, 50) 
     trip = {"doc": trip} 

     es.update(index=analytics_index, doc_type="trip-details", id=doc_id, body=trip)

但我收到此錯誤：

File "temp_updates.py", line 32, in <module> 
dump_random_values() 
File "temp_updates.py", line 30, in dump_random_values 
es.update(index=analytics_index, doc_type="trip-details", id=doc_id, body=trip) 
File "/Users/amanagarwal/Desktop/venv/analytics-django/lib/python3.5/site-packages/elasticsearch/client/utils.py", line 69, in _wrapped 
return func(*args, params=params, **kwargs) 
File "/Users/amanagarwal/Desktop/venv/analytics-django/lib/python3.5/site-packages/elasticsearch/client/__init__.py", line 460, in update 
doc_type, id, '_update'), params=params, body=body) 
File "/Users/amanagarwal/Desktop/venv/analytics-django/lib/python3.5/site-packages/elasticsearch/transport.py", line 329, in perform_request 
status, headers, data = connection.perform_request(method, url, params, body, ignore=ignore, timeout=timeout) 
File "/Users/amanagarwal/Desktop/venv/analytics-django/lib/python3.5/site-packages/elasticsearch/connection/http_urllib3.py", line 109, in perform_request 
self._raise_error(response.status, raw_data) 
File "/Users/amanagarwal/Desktop/venv/analytics-django/lib/python3.5/site-packages/elasticsearch/connection/base.py", line 108, in _raise_error 
raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, error_message, additional_info) 
elasticsearch.exceptions.RequestError: TransportError(400, 'mapper_parsing_exception', 'failed to parse')

我缺少什麼？

來源

2016-09-22 Aman Aggarwal

這是我犯的一個小錯誤。當我在Elasticsearch中查詢並更新字段值時，我應該只索引「_source」，而不是整個文檔，它包含一些額外的字段，例如「index 」，「花」等

因此這應該是代碼的變化：

def dump_random_values(): 

    query = {"size": 2000, "query": {"bool": {"must": [{"term": {"trip_client_id": {"value": 23}}}, {"type": {"value": "trip-details"}}]}}} 
    docs = es.search(index=analytics_index, doc_type="trip-details", body=query) 
    trips = docs["hits"]["hits"] 
    for trip in trips: 
     doc_id = trip["_id"] 
     current = trip["_source"] 

     current["vehicle_capacityInWeight"] = random.randint(40, 50) 
     current["shipment_packageWeight"] = random.randint(1, 39) 

     current["vehicle_capacityInVolume"] = random.randint(40, 50) 
     current["shipment_packageVolume"] = random.randint(1, 39) 

     current["shipment_packageUnits"] = random.randint(40, 50) 
     trip = {"doc": current} 

     es.update(index=analytics_index, doc_type="trip-details", id=doc_id, body=trip)

來源

2016-09-22 14:20:23

在Elasticsearch中更新文檔時出錯

回答

相關問題