Skip to content

P
physical
Commit 35c5e53f authored by 段英荣's avatar 段英荣
Browse files
Options

modify

parent b3d12ede
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
trans2es/management/commands/trans2es_data2es_parallel.py
View file @ 35c5e53f
...@@ -64,11 +64,11 @@ class Command(BaseCommand): ...@@ -64,11 +64,11 @@ class Command(BaseCommand):
#get_data_func = diary_transfer.DiaryTransfer #get_data_func = diary_transfer.DiaryTransfer
#query_set = django.db.models.QuerySet(model=md.Diary,query=md.Diary.objects.all().query) #query_set = django.db.models.QuerySet(model=md.Diary,query=md.Diary.objects.all().query)
type_name_list = get_type_info_map.keys() type_name_list = get_type_info_map().keys()
for type_name in type_name_list: for type_name in type_name_list:
type_info = get_type_info_map()[type_name] type_info = get_type_info_map()[type_name]
query_set = type_info.queryset query_set = da.queryset
slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size) slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
for chunk in slicer.chunks(): for chunk in slicer.chunks():
......
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