campaign_cost_daily.py 578 B

12345678910111213141516171819202122
  1. """
  2. 计划维度日报"""
  3. from model.DataBaseUtils import MysqlUtils
  4. from concurrent.futures import ThreadPoolExecutor
  5. from .TxCostUtils import get_accounts
  6. def run(st, et):
  7. executor = ThreadPoolExecutor(max_workers=10)
  8. for account in get_accounts():
  9. executor.submit(get_campaign_cost_daily, account[0], account[1], account[3], st, et)
  10. executor.shutdown()
  11. def get_campaign_cost_daily(account_id, token, st, et):
  12. """1,获取计划维度日报,把有消耗的计划入库
  13. 2,根据有消耗的计划,拉取计划的基础信息入库
  14. """