|
@@ -36,24 +36,24 @@ def insert_mysql(sqls):
|
|
|
print("%s mysql数据插入成功,合计%s条..." % (datetime_now(), len(sqls)))
|
|
|
|
|
|
|
|
|
-# 读取配置文件信息
|
|
|
-with open("config.json", "r") as f:
|
|
|
- data = json.load(f)
|
|
|
- mysql = data["mysql"]
|
|
|
- database = mysql["database"]
|
|
|
- dingding = data["dingding"]
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-# mysql = {
|
|
|
-# "host": os.getenv("host"),
|
|
|
-# "port": os.getenv("port"),
|
|
|
-# "user": os.getenv("user"),
|
|
|
-# "passwd": os.getenv("passwd"),
|
|
|
-# "database": os.getenv("database")
|
|
|
-# }
|
|
|
-# database = os.getenv("database")
|
|
|
-# dingding = os.getenv("dingding")
|
|
|
+# # 读取配置文件信息
|
|
|
+# with open("config.json", "r") as f:
|
|
|
+# data = json.load(f)
|
|
|
+# mysql = data["mysql"]
|
|
|
+# database = mysql["database"]
|
|
|
+# dingding = data["dingding"]
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+mysql = {
|
|
|
+ "host": os.getenv("host"),
|
|
|
+ "port": int(os.getenv("port")),
|
|
|
+ "user": os.getenv("user"),
|
|
|
+ "passwd": os.getenv("passwd"),
|
|
|
+ "database": os.getenv("database")
|
|
|
+}
|
|
|
+database = os.getenv("database")
|
|
|
+dingding = os.getenv("dingding")
|
|
|
|
|
|
|
|
|
print("%s 等待开始检查..." % datetime_now())
|