当使用django ORM时,如果要对某个模型的所有数据库行操作时,即调用all()方法时,返回的数据行数太多,就会占用大量内存,导致问题。
如果使用iterator,分块来加载指定行数的数据,就能有效减少内存的占用。
import gc
def querset_iterator(queryset, chucksize=10000):
pk = 0
last_pk = queryset.order_by('-pk')[0]
queryset.order_by('pk')
while pk < last_pk:
for row in queryset.filter(pk__gt=pk)[:chucksize]:
# 每次读入内存的行数最大为chucksize
yield row
pk = row.id
gc.collect()
# gc垃圾回收