众妙音信——BUG

zhongmiaoyinxin/zhongmiaoyinxin_recommend/zhongmiaoyinxin_recommend_new.py

@@ -27,7 +27,6 @@ class ZMYXRecommend:
     log_type = None
 
     def __init__(self, log_type, crawler, env, rule_dict, our_uid):
-        self.mq = None
         self.platform = "zhongmiaoyinxin"
         self.download_cnt = 0
         self.element_list = []
@@ -38,6 +37,7 @@ class ZMYXRecommend:
         self.env = env
         self.rule_dict = rule_dict
         self.our_uid = our_uid
+        self.mq = MQ(topic_name="topic_crawler_etl_" + self.env)
         if self.env == "dev":
             chromedriverExecutable = "/Users/luojunhui/Downloads/chromedriver_V111/chromedriver"
         else: