_run_update2.py 474 B

123456789101112
  1. # -*- coding: utf-8 -*-
  2. import sys, io
  3. sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding='utf-8')
  4. from loguru import logger
  5. logger.remove()
  6. logger.add(sys.stderr, format="[{time:HH:mm:ss}] {message}", level="INFO")
  7. import super_vault_daily_spider as s
  8. from mysql_pool import MySQLConnectionPool
  9. pool = MySQLConnectionPool(log=logger)
  10. token = pool.select_one("SELECT token FROM super_vault_token")[0]
  11. s.update_stale_products(logger, pool, token)
  12. print("UPDATE_DONE")