pictorial_topic_sort 接口指定索引名

libs/es.py

@@ -188,19 +188,22 @@ class ESPerform(object):
     @classmethod
     def get_search_results(cls, es_cli, sub_index_name, query_body, offset=0, size=10,
                            auto_create_index=False, doc_type="_doc", aggregations_query=False, is_suggest_request=False,
-                           batch_search=False, routing=None):
+                           batch_search=False, routing=None,if_official_index_name=False):
         try:
             assert (es_cli is not None)
 
-            official_index_name = cls.get_official_index_name(sub_index_name, "read")
-            index_exists = es_cli.indices.exists(official_index_name)
-            if not index_exists:
-                if not auto_create_index:
-                    logging.error("index:%s is not existing,get_search_results error!" % official_index_name)
-                    return None
-                else:
-                    cls.create_index(es_cli, sub_index_name)
-                    cls.put_index_mapping(es_cli, sub_index_name)
+            if if_official_index_name:
+                official_index_name = if_official_index_name
+            else:
+                official_index_name = cls.get_official_index_name(sub_index_name, "read")
+                index_exists = es_cli.indices.exists(official_index_name)
+                if not index_exists:
+                    if not auto_create_index:
+                        logging.error("index:%s is not existing,get_search_results error!" % official_index_name)
+                        return None
+                    else:
+                        cls.create_index(es_cli, sub_index_name)
+                        cls.put_index_mapping(es_cli, sub_index_name)
 
             logging.info("duan add,query_body:%s" % str(query_body).encode("utf-8"))
 

search/views/group.py

@@ -420,7 +420,7 @@ def pictorial_topic_sort(pictorial_id=-1, offset=0, size=10, sort_type=PICTORIAL
         pict_pictorial_ids_list = []
         # 获取es链接对象
         es_cli_obj = ESPerform.get_cli()
-        result_dict = ESPerform.get_search_results(es_cli_obj, "topic", q, offset, size)
+        result_dict = ESPerform.get_search_results(es_cli=es_cli_obj, sub_index_name="mv-alpha-topic-prod-190905001", query_body=q, offset=offset, size=size,if_official_index_name=True)
 
         # logging.info("get pictorial_topic_sort res:%s" % result_dict)