no message

Pyspark_job/listen_program/site_search_term_to_syn.py

@@ -28,6 +28,11 @@ class Integrate_search_term():
         self.engine_mysql = DBUtil.get_db_engine("mysql", "us")
         self.date_info_pre = self.get_pre_week(date_info)
         self.date_type = date_type
+        self.site_name_pri_dict = {
+            "us": 1,
+            "uk": 3,
+            "de": 5,
+        }
 
     def fetch_year_month_by_week(self):
         if self.date_type == 'week':
@@ -90,6 +95,7 @@ class Integrate_search_term():
                 conn.execute(deletesql)
 
             with self.engine_mysql.begin() as conn:
+                priority = self.site_name_pri_dict[self.site_name]
                 update_sql_workflow = f"""
                                         INSERT INTO workflow_manager
                         (
@@ -110,7 +116,7 @@ class Integrate_search_term():
                             '{self.site_name}',
                             'month',
                             '{self.date_info}',
-                            1,
+                            {priority},
                             'us_spider_st',
                             'yes',
                             1,