main.py 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. import argparse
  2. import logging
  3. import time
  4. from logging.handlers import TimedRotatingFileHandler
  5. import tornado.ioloop
  6. import tornado.log
  7. import tornado.options
  8. import tornado.web
  9. import ai_callback_add_creative_handler
  10. import ai_callback_add_group_handler
  11. import ai_strategy_request_handler
  12. def create_application():
  13. # 日志的格式
  14. log_formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s',
  15. '%m/%d/%Y %I:%M:%S %p')
  16. # ai策略请求解析的日志对象-----------------------------------------------------------
  17. ai_strategy_request_log_handler = TimedRotatingFileHandler("logs/add_group_log/ai_strategy_request.log",
  18. when="midnight",
  19. backupCount=100)
  20. ai_strategy_request_log_handler.setFormatter(log_formatter)
  21. ai_strategy_request_logger = logging.getLogger('ai_strategy_request_logger')
  22. ai_strategy_request_logger.addHandler(ai_strategy_request_log_handler)
  23. ai_strategy_request_logger.setLevel(logging.DEBUG)
  24. print("ai_strategy_request_logger's id is {}".format(id(ai_strategy_request_logger)))
  25. msg = "ai strategy request service started at {t}".\
  26. format(t=time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
  27. ai_strategy_request_logger.info(msg)
  28. # 创建广告组回调日志对象-----------------------------------------------------------
  29. ai_callback_add_group_log_handler = TimedRotatingFileHandler("logs/add_group_log/ai_callback_add_group.log",
  30. when="midnight",
  31. backupCount=100)
  32. ai_callback_add_group_log_handler.setFormatter(log_formatter)
  33. ai_callback_add_group_logger = logging.getLogger('ai_callback_add_group_logger')
  34. ai_callback_add_group_logger.addHandler(ai_callback_add_group_log_handler)
  35. ai_callback_add_group_logger.setLevel(logging.DEBUG)
  36. print("ai_callback_add_group_logger's id is {}".format(id(ai_callback_add_group_logger)))
  37. msg = "ai callback add group logger service started at {t}". \
  38. format(t=time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
  39. ai_callback_add_group_logger.info(msg)
  40. # 创建广告创意回调日志对象-----------------------------------------------------------
  41. ai_callback_add_creative_log_handler = TimedRotatingFileHandler("logs/add_group_log/ai_callback_add_creative.log",
  42. when="midnight",
  43. backupCount=100)
  44. ai_callback_add_creative_log_handler.setFormatter(log_formatter)
  45. ai_callback_add_creative_logger = logging.getLogger('ai_callback_add_creative_logger')
  46. ai_callback_add_creative_logger.addHandler(ai_callback_add_creative_log_handler)
  47. ai_callback_add_creative_logger.setLevel(logging.DEBUG)
  48. print("ai_callback_add_creative_logger's id is {}".format(id(ai_callback_add_creative_logger)))
  49. msg = "ai callback add creative logger service started at {t}". \
  50. format(t=time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
  51. ai_callback_add_creative_logger.info(msg)
  52. web_application = tornado.web.Application([
  53. (r"/ai_strategy_request",
  54. ai_strategy_request_handler.AiStrategyRequestParse,
  55. {"logger": ai_strategy_request_logger}),
  56. (r"/ai_callback_add_group",
  57. ai_callback_add_group_handler.AiCallBackAddGroup,
  58. {"logger": ai_callback_add_group_logger}),
  59. (r"/ai_callback_add_creative",
  60. ai_callback_add_creative_handler.AiCallBackAddCreative,
  61. {"logger": ai_callback_add_creative_logger}),
  62. ])
  63. return web_application
  64. if __name__ == "__main__":
  65. parser = argparse.ArgumentParser()
  66. parser.add_argument('-p', '--port', type=int, default=31012)
  67. args = parser.parse_args()
  68. application = create_application()
  69. application.listen(args.port)
  70. tornado.ioloop.IOLoop.instance().start()