|
@@ -10,9 +10,15 @@ INSERT_SQL = "replace into %s.%s(project_id,date,energy_cooling,energy_heating,e
|
|
DELETE_SQL = "DELETE FROM `energy_week_day` WHERE `project_id` = '%s' AND `date` >= '%s' AND `date` < '%s' "
|
|
DELETE_SQL = "DELETE FROM `energy_week_day` WHERE `project_id` = '%s' AND `date` >= '%s' AND `date` < '%s' "
|
|
|
|
|
|
def datetime_now():
|
|
def datetime_now():
|
|
- datetime_now = datetime.datetime.now().strftime("%Y%m%d%H%M%S")
|
|
|
|
|
|
+ # datetime_now = datetime.datetime.now().strftime("%Y%m%d%H%M%S")
|
|
|
|
+ #容器时间
|
|
|
|
+ # tz = pytz.timezone('Asia/Shanghai') # 东八区
|
|
|
|
+ datetime_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
|
|
+ pytz.timezone('Asia/Shanghai')).strftime('%Y%m%d%H%M%S')
|
|
return datetime_now
|
|
return datetime_now
|
|
|
|
|
|
|
|
+
|
|
|
|
+
|
|
# 获取能耗数据
|
|
# 获取能耗数据
|
|
def get_data_time(hbase_database, hbase_table, building, from_time, to_time):
|
|
def get_data_time(hbase_database, hbase_table, building, from_time, to_time):
|
|
Criteria = {
|
|
Criteria = {
|
|
@@ -70,12 +76,12 @@ my_database = os.getenv("database")
|
|
print("同步%s项目数据"%(building))
|
|
print("同步%s项目数据"%(building))
|
|
while True:
|
|
while True:
|
|
# 容器里获取时间
|
|
# 容器里获取时间
|
|
- tz = pytz.timezone('Asia/Shanghai') # 东八区
|
|
|
|
|
|
+ # tz = pytz.timezone('Asia/Shanghai') # 东八区
|
|
time_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
time_now = datetime.datetime.fromtimestamp(int(time.time()),
|
|
pytz.timezone('Asia/Shanghai')).strftime('%H:%M:%S')
|
|
pytz.timezone('Asia/Shanghai')).strftime('%H:%M:%S')
|
|
# time_now = time.strftime("%H:%M:%S", time.localtime()) # 刷新
|
|
# time_now = time.strftime("%H:%M:%S", time.localtime()) # 刷新
|
|
- am_set_time = "15:00:00"
|
|
|
|
- pm_set_time = "04:00:00"
|
|
|
|
|
|
+ am_set_time = "16:34:00"
|
|
|
|
+ pm_set_time = "22:00:00"
|
|
if time_now == am_set_time or time_now ==pm_set_time:#此处设置每天定时的时间
|
|
if time_now == am_set_time or time_now ==pm_set_time:#此处设置每天定时的时间
|
|
today = datetime.date.today().strftime("%Y%m%d")
|
|
today = datetime.date.today().strftime("%Y%m%d")
|
|
yesterday = (datetime.date.today()-datetime.timedelta(days=1)).strftime("%Y%m%d")
|
|
yesterday = (datetime.date.today()-datetime.timedelta(days=1)).strftime("%Y%m%d")
|