utils_logs_handle.py 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. # -*- coding: UTF-8 -*-
  2. '''
  3. 获取每天日期,新建 logs 文件
  4. 存到 logs 文件夹中
  5. '''
  6. import time
  7. from datetime import datetime
  8. import os
  9. import sys
  10. sys.path.append(os.path.join(os.path.abspath(__file__).split('auto')[0] + 'auto'))
  11. from utils.utils_mongo_handle import MongoHandle
  12. from base.base_load_config import load_config, get_base_path
  13. config_json = load_config()
  14. base_project = get_base_path()
  15. class LogsHandle(object):
  16. def __init__(self):
  17. self.now_day = time.strftime('%Y-%m-%d', time.localtime())
  18. db = 'logs'
  19. collection = 'logs_' + self.now_day
  20. self.mongo = MongoHandle(db=db, collection=collection, del_db=False, del_collection=False, auto_remove=0)
  21. def logs_generate(self):
  22. data_to_insert = {
  23. "title": "logs",
  24. "context": 'generate logs',
  25. "state": "create",
  26. "create_time": int(time.time()),
  27. "create_datetime": datetime.now().strftime("%Y-%m-%d %H:%M:%S")
  28. }
  29. self.mongo.collection.insert_one(data_to_insert)
  30. def logs_send(self):
  31. subject = 'auto collection logs'
  32. title = 'auto collection - logs: {}'.format(self.now_day)
  33. text = ''
  34. # TODO
  35. # 从 mongodb 读取日志, 拼接 text, 发送邮件
  36. # 查询所有文档
  37. cursor = self.mongo.collection.find()
  38. # 遍历结果集
  39. for record in cursor:
  40. text += "logs_source: {}, logs_detail: {}, state: {} logs_create_time: {}\n\n".format(
  41. record.setdefault('title'),
  42. record.setdefault('content'),
  43. record.setdefault('state'),
  44. record.setdefault('create_datetime'),
  45. )
  46. S = SendEmail(subject=subject, title=title, text=text)
  47. S.send()
  48. def logs_write(self, title_source=None, content=None, state=None, send_now=False):
  49. data_to_insert = {
  50. "title": title_source,
  51. "context": content,
  52. "state": state,
  53. "create_time": int(time.time()),
  54. "create_datetime": datetime.now().strftime("%Y-%m-%d %H:%M:%S")
  55. }
  56. self.mongo.collection.insert_one(data_to_insert)
  57. if send_now:
  58. subject = 'auto collection'
  59. title = 'auto collection - running logs: {}'.format(self.now_day)
  60. text = 'logs_source: {}, logs_detail: {}, state: {} logs_create_time: {}'.format(
  61. data_to_insert.setdefault('title'),
  62. data_to_insert.setdefault('content'),
  63. data_to_insert.setdefault('state'),
  64. data_to_insert.setdefault('create_datetime'),
  65. )
  66. Send = SendEmail(subject=subject, title=title, text=text)
  67. Send.send()