from sqlalchemy import select
from .models import Order, db
def stream_orders(batch_size=1000):
import csv
class _LineBuffer:
def __init__(self):
self._data = ""
from sqlalchemy import select
from sqlalchemy.orm import Session
from .models import User
BATCH_SIZE = 1000