|
@@ -41,27 +41,27 @@ def get_data_time(zillionUtil,hbase_database, hbase_table, building, meter,funid
|
|
|
|
|
|
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-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")
|
|
|
-hbase_database = os.getenv("hbase_database")
|
|
|
-url = os.getenv("url")
|
|
|
-sleep = os.getenv("sleep")
|
|
|
-dingding = os.getenv("dingding")
|
|
|
+with open("config.json", "r") as f:
|
|
|
+ data = json.load(f)
|
|
|
+ hbase_database = data["metadata"]["database"]
|
|
|
+ url = data["metadata"]["url"]
|
|
|
+ mysql = data["mysql"]
|
|
|
+ my_database = mysql["database"]
|
|
|
+ dingding = data["dingding"]
|
|
|
+ sleep = data["sleep"]
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
timedelta_5min = (datetime.datetime.now() - datetime.timedelta(minutes=5)).strftime(f"%Y%m%d%H%M")
|