kuaishou recommend etl

kuaishou/kuaishou_recommend/kuaishou_recommend_cut_title.py

@@ -60,7 +60,7 @@ class KuaiShouRecommendScheduling:
 
     @classmethod
     def get_videoList(cls, log_type, crawler, our_uid, rule_dict, env):
-        mq = MQ(topic_name="topic_crawler_etl_dev")
+        mq = MQ(topic_name="topic_crawler_etl_" + env)
         for page in range(1, 101):
             try:
                 Common.logger(log_type, crawler).info(f"正在抓取第{page}页")