|
@@ -216,7 +216,7 @@ def func_2(delete_list):
|
|
conn = SP_ETL(**AWS_CREDENTIALS).clickhouse_connect()
|
|
conn = SP_ETL(**AWS_CREDENTIALS).clickhouse_connect()
|
|
date_list = []
|
|
date_list = []
|
|
for table_name in delete_list:
|
|
for table_name in delete_list:
|
|
- check_date = (datetime.today() + timedelta(days=14)).date().isoformat()
|
|
|
|
|
|
+ check_date = (datetime.today() + timedelta(days=-14)).date().isoformat()
|
|
try:
|
|
try:
|
|
locals()[table_name] = conn.query_df(
|
|
locals()[table_name] = conn.query_df(
|
|
f"select date,SUM(impressions) as impressions from AmazonReport.`{table_name}` where date >='{check_date}' group by date,profileId")
|
|
f"select date,SUM(impressions) as impressions from AmazonReport.`{table_name}` where date >='{check_date}' group by date,profileId")
|