panda/saas
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ngv每日更新存储数据源数据

Browse Source
This commit is contained in:
z66
2025-11-03 11:50:25 +08:00
parent 1d5bf7cd55
commit 027a66b973
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
back_ground_module/update_NGV_data.py
+3
View File
@@ -49,6 +49,9 @@ class UpdateNGVData:
data_NGV_j = common_module.get_ngv_details(days_back=1) data_NGV_j = common_module.get_ngv_details(days_back=1)
data_NGV_j1 = common_module.get_ngv_details(days_back=2) data_NGV_j1 = common_module.get_ngv_details(days_back=2)
data_NGV_j.to_csv(os.path.join(output_dir, f"{task_start_time}up_NGV_j.csv"))
data_NGV_j1.to_csv(os.path.join(output_dir, f"{task_start_time}up_NGV_j1.csv"))
# 找出在 data_NGV_j 中存在但在 data_NGV_j1 中不存在的 data_id # 找出在 data_NGV_j 中存在但在 data_NGV_j1 中不存在的 data_id
unique_data_ids = data_NGV_j[~data_NGV_j['org_code'].isin(data_NGV_j1['org_code'])] unique_data_ids = data_NGV_j[~data_NGV_j['org_code'].isin(data_NGV_j1['org_code'])]