historyTask.py 556 B

123456789101112131415161718192021222324252627
  1. """
  2. @author: luojunhui
  3. """
  4. import time
  5. import asyncio
  6. import datetime
  7. from tasks.history_task import historyContentIdTask
  8. from applications.db import TaskMySQLClient
  9. async def main():
  10. """
  11. main job
  12. :return:
  13. """
  14. TMC = TaskMySQLClient()
  15. await TMC.init_pool()
  16. PD = historyContentIdTask(TMC)
  17. await PD.deal()
  18. if __name__ == '__main__':
  19. while True:
  20. asyncio.run(main())
  21. now_str = datetime.datetime.now().__str__()
  22. print("{} 请求执行完成, 等待60s".format(now_str))
  23. time.sleep(60)