import json
from DB import DBVidcon
payload_list = []
db = DBVidcon()
rows = db.get_report_video()
push  = db.push_report

# =======================

for row in rows:
    payload_list.append(json.dumps({**row}, ensure_ascii=False))
    if len(payload_list) >= 10000:
        push(payload_list)
        payload_list.clear()
if payload_list:  # 收尾
    push(payload_list)

db.close()