kimiTask.py 501 B

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