提交 42ed3763 编写于 作者: 6 62f3568c7066201db17ad50a

更新了日志存放格式

上级 d4c975ad
此差异已折叠。
{"token": "svlvn009upg", "user": "movie_201216shus"}
\ No newline at end of file
{"token": "d2fdj55bqu8", "user": "movie_201216shus"}
\ No newline at end of file
......@@ -16,4 +16,5 @@ def get_video_resource(video_name):
return get_resource_by_token(token, video_name)
if __name__ == '__main__':
app.run(host="0.0.0.0", port=5000, debug=True)
print(' * log path: ./service/resource/logs')
app.run(host="0.0.0.0", port=5000, debug=False)
from cgitb import enable
import requests
import logging
import json
......@@ -24,16 +23,18 @@ with open('./resource/video/domain', 'r') as file:
IS_TOKEN = True
TOKEN_ERROR = 'CANNOT_GET_TOKEN_ERROR'
logging.basicConfig(level = logging.DEBUG,
format = '%(asctime)s - %(name)s - %(levelname)s - %(message)s', filename='./resource/logs/video_log')
logger = logging.getLogger(__name__)
video_log_file = logging.FileHandler(filename='./resource/logs/video_log', mode='a', encoding='utf-8')
log_format = logging.Formatter(fmt="%(asctime)s - %(name)s - %(levelname)s -%(module)s: %(message)s")
video_log_file.setFormatter(log_format)
logger = logging.Logger(name='video', level=logging.DEBUG)
logger.addHandler(video_log_file)
def get_token_by_request():
global HEADER
with open('./resource/video/token', 'r') as file:
token_url = file.readline()
logging.debug(f'Get token from {token_url=}')
logger.debug(f'Get token from {token_url=}')
return requests.get(domain + token_url, headers=HEADER).json()
def get_token():
......@@ -43,19 +44,19 @@ def get_token():
return TOKEN_ERROR
try:
token = get_token_by_request()
logging.debug(f'Get token success: {token=}')
logger.debug(f'Get token success: {token=}')
with open('./resource/video/token_backup', 'w') as file:
token['user'] = 'movie_' + token['user'][0]
file.write(json.dumps(token))
logging.debug(f'Get token successed! Write to ./resource/token_backup')
logger.debug(f'Get token successed! Write to ./resource/token_backup')
return token
except requests.exceptions.JSONDecodeError:
with open('./resource/token_backup', 'r') as file:
token = json.loads(file.readline())
logging.warning(f'JSONDecodeError: Get token failed!, Read backup local token from ./resource/token_backup')
logger.warning(f'JSONDecodeError: Get token failed!, Read backup local token from ./resource/token_backup')
return token
except Exception as e:
logging.error(f'{e}: The url of get token is not normal, please check service configruation now!')
logger.error(f'{e}: The url of get token is not normal, please check service configruation now!')
IS_TOKEN = False
return TOKEN_ERROR
......@@ -70,7 +71,7 @@ def get_resource_by_token(token, name):
PAYLOAD["whr"] = f'question like "%{name}%" or byname like "%{name}%"'
PAYLOAD["token"] = token["token"]
logging.debug(f'Get {PAYLOAD=}')
logger.debug(f'Get {PAYLOAD=}')
video_list = []
......@@ -78,15 +79,16 @@ def get_resource_by_token(token, name):
try:
url = url.replace('\n', '')
video = requests.post(domain + url, headers=HEADER, data=PAYLOAD)
logging.debug(f'{url}: {video}')
logger.debug(f'{url}: {video}')
if not check_json_format(video.text):
logging.debug(f'{url}: Get text is not a json, {video.text}')
logger.debug(f'{url}: Get text is not a json,\n {video.text}')
continue
video = video.json()
if len(video['list']) > 0:
video_list.append(video['list'])
except Exception as e:
logging(f'{e}:Get video resource from {url} failed!')
logger.error(f'{e}:Get video resource from {url} failed!')
continue
return video_list
def check_json_format(raw_msg):
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册