Пакетный запрос для обновления, потому что время операции истекло

Question

Я выполняю следующую миграцию данных в SQLAlchemy, и время операции истекает, поэтому я хотел бы пакетировать запрос таким образом, чтобы я мог завершить миграцию.

session = Session()
q = session.query(RawDocument)

for i in q:
    my_tf_dict = get_word_count(i)
    new_ob = ten_q()
    new_ob.tf_dict_phrases = my_tf_dict
    session.add(new_ob)
    del my_tf_dict

session.commit()

Я думаю, yield_per() может быть вариант? https://www.codepowered.com/manuals/SQLAlchemy-0.6.9-doc/html/orm/query.html

Кроме того, может быть, применение этих методов может работать? https://carto.com/docs/carto-engine/sql-api/batch-queries/

Таблица, которую я пытаюсь обновить:

id     cik  tf_dict_phrase  factset_id                   key_name
1   706688                  000BFT-E    10q/706688_2005-5-10_10-Q
2   706688                  000BFT-E    10q/706688_2005-8-8_10-Q
3   706688                  000BFT-E    10q/706688_2005-11-8_10-Q