Commit 75021676 authored by lixiaofang's avatar lixiaofang

catch exe

parent 132510dc
......@@ -104,9 +104,13 @@ class Command(BaseCommand):
def __sync_data_by_type(self, type_name):
try:
type_info = get_type_info_map()[type_name]
logging.info("begin .........!:%s" % type_name)
query_set = type_info.queryset
slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
logging.info("begin .........!:%s" % slicer)
for chunk in slicer.chunks():
job = Job(
sub_index_name=type_name,
......@@ -120,10 +124,8 @@ class Command(BaseCommand):
def handle(self, *args, **options):
try:
type_name_list = get_type_info_map().keys()
logging.info("begin .........!:%s" % type_name_list)
for type_name in type_name_list:
logging.info("begin .........!:%s" % type_name)
if len(options["type"]):
if options["type"] == "all" or type_name == options["type"]:
logging.info("begin sync [%s] data to es!" % type_name)
......
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