Optim: Use filtered query instead of post filter to fetch by id in ES

idunn/api/pages_jaunes.py

@@ -57,7 +57,9 @@ def get_place(self, id):
         internal_id = id.replace(f"{self.PLACE_ID_NAMESPACE}:", "", 1)
 
         es_places = self.es.search(
-            index=self.es_index, body={"filter": {"term": {"_id": internal_id}}}
+            index=self.es_index,
+            body={"query": {"bool": {"filter": {"term": {"_id": internal_id}}}}},
+            ignore_unavailable=True,
         )
 
         es_place = es_places.get("hits", {}).get("hits", [])

idunn/api/utils.py

@@ -139,14 +139,7 @@ def fetch_es_poi(id, es) -> dict:
     This function gets from Elasticsearch the
     entry corresponding to the given id.
     """
-    es_pois = es.search(
-        index=PLACE_POI_INDEX, body={"filter": {"term": {"_id": id}}}, ignore_unavailable=True
-    )
-
-    es_poi = es_pois.get("hits", {}).get("hits", [])
-    if len(es_poi) == 0:
-        raise HTTPException(status_code=404, detail=f"poi '{id}' not found")
-    return es_poi[0]["_source"]
+    return fetch_es_place(id, es, type="poi")["_source"]
 
 
 def fetch_bbox_places(es, indices, raw_filters, bbox, max_size) -> list:
@@ -217,7 +210,10 @@ def fetch_es_place(id, es, type) -> dict:
 
     try:
         es_places = es.search(
-            index=index_name, body={"filter": {"term": {"_id": id}}}, ignore_unavailable=True,
+            index=index_name,
+            body={"query": {"bool": {"filter": {"term": {"_id": id}}}}},
+            ignore_unavailable=True,
+            _source_exclude=["boundary"],
         )
     except ElasticsearchException as error:
         logger.warning(f"error with database: {error}")

tests/test_api.py

@@ -88,12 +88,12 @@ def test_block_null():
     assert resp["blocks"][0]["url"] == "tel:+33142720937"
 
 
-def test_unknow_poi():
+def test_unknown_poi():
     client = TestClient(app)
     response = client.get(url="http://localhost/v1/pois/an_unknown_poi_id",)
 
     assert response.status_code == 404
-    assert response.json() == {"detail": "poi 'an_unknown_poi_id' not found"}
+    assert "'an_unknown_poi_id' not found" in response.json()["detail"]
 
 
 def test_services_and_information():