|
|
@@ -1,10 +1,25 @@
|
|
|
import requests
|
|
|
import sqlite3
|
|
|
import json
|
|
|
-import time
|
|
|
+import os
|
|
|
import datetime
|
|
|
from weather import all_city
|
|
|
+import logging
|
|
|
|
|
|
+# 配置日志级别和格式
|
|
|
+logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
|
|
|
+
|
|
|
+# 创建一个文件处理器,指定日志文件名和写入模式
|
|
|
+os.mkdir("/data/weather/") if not os.path.exists("/data/weather/") else None
|
|
|
+file_handler = logging.FileHandler('/data/weather/app.log')
|
|
|
+file_handler.setLevel(logging.INFO)
|
|
|
+
|
|
|
+# 创建一个格式化程序,用于定义日志消息的显示方式
|
|
|
+formatter = logging.Formatter('%(asctime)s - %(levelname)s - %(message)s')
|
|
|
+file_handler.setFormatter(formatter)
|
|
|
+
|
|
|
+# 将文件处理器添加到根日志记录器中
|
|
|
+logging.getLogger('').addHandler(file_handler)
|
|
|
|
|
|
app_id = "69334222"
|
|
|
app_secret = "2u4bHXHD"
|
|
|
@@ -145,6 +160,7 @@ def main():
|
|
|
server_day_response = requests.get(server_day_url)
|
|
|
server_day_data = json.loads(server_day_response.text)
|
|
|
if "errcode" not in server_day_data.keys():
|
|
|
+ logging.warning(f"{province, city, district} server day weather success")
|
|
|
server_sql = f"""
|
|
|
INSERT OR REPLACE INTO `server_day_data` (`id`,`province`, `city`, `district`, `content`) VALUES (?, ?, ?, ?, ?)
|
|
|
"""
|