|
@@ -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": int(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())
|