|
@@ -1,6 +1,11 @@
|
|
|
+"""
|
|
|
+Created on Wednesday, February 28
|
|
|
+@author: 罗俊辉
|
|
|
+
|
|
|
+"""
|
|
|
import time
|
|
|
import schedule
|
|
|
-import datetime
|
|
|
+from datetime import datetime, timedelta
|
|
|
|
|
|
from functions.odps_function import OdpsFunction
|
|
|
from functions.feishu import Feishu
|
|
@@ -8,6 +13,14 @@ from functions.config import column_map, alg_map, yesterday_columns
|
|
|
from functions.get_yesterday_data import find_yesterday_data
|
|
|
|
|
|
|
|
|
+def get_yesterday_str():
|
|
|
+ """获取昨天的日期字符"""
|
|
|
+ today = datetime.now()
|
|
|
+ # 计算昨天的日期
|
|
|
+ yesterday = today - timedelta(days=1)
|
|
|
+ return yesterday.strftime('%Y%m%d')
|
|
|
+
|
|
|
+
|
|
|
def read_odps_data(date_info):
|
|
|
"""
|
|
|
从 odps 读取数据
|
|
@@ -29,7 +42,7 @@ def process_data(data_obj):
|
|
|
temp = {}
|
|
|
for key in keys:
|
|
|
try:
|
|
|
- temp[key] = round(float(data_obj[key]))
|
|
|
+ temp[key] = int(data_obj[key])
|
|
|
except:
|
|
|
temp[key] = data_obj[key]
|
|
|
# 获取昨天的数据并且更新到 temp 中
|
|
@@ -37,7 +50,6 @@ def process_data(data_obj):
|
|
|
yes_d = find_yesterday_data(column)
|
|
|
if type(yes_d) != str:
|
|
|
temp[column_map[column]] = yes_d
|
|
|
- # if temp[column_map[column]] != "-" or temp[column_map[column]] != "--":
|
|
|
|
|
|
result = []
|
|
|
for key in temp:
|
|
@@ -67,8 +79,11 @@ def main():
|
|
|
F.prepend_value(sheet_id="Zi7oYW", values=[[0]], ranges="A5:A5")
|
|
|
|
|
|
# 读数据
|
|
|
- date_info = datetime.date.today().__str__().replace("-", "")
|
|
|
+ # date_info = get_yesterday_str()
|
|
|
+ date_info = "20240225"
|
|
|
ori_data = read_odps_data(date_info)
|
|
|
+ if not ori_data:
|
|
|
+ return
|
|
|
|
|
|
# 处理元数据
|
|
|
data_list = process_data(ori_data)
|
|
@@ -86,3 +101,4 @@ if __name__ == "__main__":
|
|
|
schedule.run_pending()
|
|
|
time.sleep(1)
|
|
|
# main()
|
|
|
+ # print(get_yesterday_str())
|