更新es的配置

injection/data_sync/tasks.py

@@ -13,6 +13,9 @@ from rpc.all import get_rpc_remote_invoker
 @shared_task
 @thread_local(DB_FOR_READ_OVERRIDE=settings.DBMW_SLAVE_DB_NAME)
 def write_to_es(es_type, pk_list, configuration, use_batch_query_set=False, es_config=None):
+    if es_type in ["service", 'sku']:
+        es_config = False
+
     pk_list = list(frozenset(pk_list))
     type_info_map = get_type_info_map()
     type_info = type_info_map[es_type]