func_insertion1.py

def process_and_insert(batch):
  for tablename in tablenams:
    # some processing for each typeof table.
      db.insert(batch, tablename)

def insert_function(resultiterator, tablenames):
  for batch in iterator_function(resultiterator):
    process_and_insert(batch, tablenames)

func_proto1.py

def iterator_function(resultiterator):
  list_for_batch_size = []
  for obj in resultiterator:
    list_for_batch_size.append(obj)
    if len(list_for_batch_size) == BATCH_SIZE:
      yield(list_for_batch_size)
  # for left records after last iteration.
  yield(list_of_batch_size)