Commit a5f6b6aa authored by 段英荣's avatar 段英荣

modify

parent 6deba07f
...@@ -24,7 +24,7 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False): ...@@ -24,7 +24,7 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
logging.info("consume es_type:%s" % str(es_type)) logging.info("consume es_type:%s" % str(es_type))
type_info.insert_table_by_pk_list( type_info.insert_table_by_pk_list(
sub_index_name=es_type, sub_index_name=type_info.name,
pk_list=pk_list, pk_list=pk_list,
use_batch_query_set=use_batch_query_set, use_batch_query_set=use_batch_query_set,
es=ESPerform.get_cli() es=ESPerform.get_cli()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment