no message

Pyspark_job/dwd/dwd_st_asin_measure.py

@@ -126,6 +126,8 @@ class DwdStMeasure(Templates):
 
         if date_type in ['month', 'month_week'] and ((self.site_name == 'us' and date_info >= '2023-10') or (self.site_name in ['uk', 'de'] and self.date_info >= '2024-05')):
             sql = f"select * from dim_st_asin_info where site_name='{self.site_name}' and date_type='month' and date_info ='{self.date_info}'"
+        elif date_type in ['month_aba_me']:
+            sql = f"select * from dim_st_asin_info where site_name='{self.site_name}' and date_type='month_aba_me' and date_info ='{self.date_info}'"
 
         # else:
         #     if (int(self.year) == 2022 and int(self.month) < 10) or int(self.year) <= 2021:
@@ -239,6 +241,8 @@ class DwdStMeasure(Templates):
         self.handle_join()
         self.df_save_asin = self.handle_st_asin_counts(cal_type="asin", df_templates=self.df_asin_templates, page=3)
         self.df_save_st = self.handle_st_asin_counts(cal_type="st", df_templates=self.df_st_templates)
+        self.df_save_st.show(10, truncate=False)
+        print(f"self.df_save_st: {self.df_save_st.count()}")
         # self.handle_st_zr_page1_title_rate()
         self.handle_st_zr_sp_page123_title_rate(data_type='zr', page_type='page1')
         self.handle_st_zr_sp_page123_title_rate(data_type='zr', page_type='page123')
@@ -708,6 +712,7 @@ class DwdStMeasure(Templates):
         ).join(
             df_st_flow_proportion_matrix, on=['search_term'], how='left'
         )
+        print(f"{'===' * 10}, self.df_save_st: {self.df_save_st.count()}")
         self.df_save_st.show(10, truncate=False)
 
     def handle_st_num(self):