企业动态topic调整

comData/Tyc/fbs_tyc_qydt.py

@@ -226,7 +226,7 @@ def beinWork(tyc_code, social_code):
                 continue
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'])
-                kafka_result = producer.send("researchReportTopic",
+                kafka_result = producer.send("researchReportDynamicTopic",
                                              json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
 
                 print(kafka_result.get(timeout=10))

comData/Tyc/newsbucai.py

@@ -256,7 +256,7 @@ def beinWork(tyc_code, social_code,start_time):
                 # 将相应字段通过kafka传输保存
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'])
-                kafka_result = producer.send("researchReportTopic",
+                kafka_result = producer.send("researchReportDynamicTopic",
                                              json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
 
                 print(kafka_result.get(timeout=10))

comData/Tyc/newsbucai1.py

@@ -265,7 +265,7 @@ def beinWork(tyc_code, social_code,start_time):
                 # 将相应字段通过kafka传输保存
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'])
-                kafka_result = producer.send("researchReportTopic",
+                kafka_result = producer.send("researchReportDynamicTopic",
                                              json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
 
                 print(kafka_result.get(timeout=10))

comData/Tyc/tyc_qydt_add.py

@@ -247,7 +247,7 @@ def beinWork(tyc_code, social_code,start_time):
                 # 将相应字段通过kafka传输保存
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'])
-                kafka_result = producer.send("researchReportTopic",
+                kafka_result = producer.send("researchReportDynamicTopic",
                                              json.dumps(dic_news, ensure_ascii=False).encode('utf8'))
 
                 print(kafka_result.get(timeout=10))

comData/YanBao/resentYanbao.py

@@ -964,28 +964,28 @@ if __name__ == '__main__':
     #     shijiejingjiluntan()
     # except:
     #     pass
-    try:
-        log.info('dongfangcaifu')
-        dongfangcaifu()
-    except:
-        pass
-    try:
-        log.info('dongfangcaifu2')
-        dongfangcaifu2()
-    except:
-        pass
-
-    try:
-        log.info('dongfangcaifu3')
-        dongfangcaifu3()
-    except Exception as e:
-        pass
-
-    try:
-        log.info('dongfangcaifu4')
-        dongfangcaifu4()
-    except:
-        pass
+    # try:
+    #     log.info('dongfangcaifu')
+    #     dongfangcaifu()
+    # except:
+    #     pass
+    # try:
+    #     log.info('dongfangcaifu2')
+    #     dongfangcaifu2()
+    # except:
+    #     pass
+    #
+    # try:
+    #     log.info('dongfangcaifu3')
+    #     dongfangcaifu3()
+    # except Exception as e:
+    #     pass
+    #
+    # try:
+    #     log.info('dongfangcaifu4')
+    #     dongfangcaifu4()
+    # except:
+    #     pass
 
     try:
         log.info('dongfangcaifu5')
@@ -993,14 +993,14 @@ if __name__ == '__main__':
     except:
         pass
 
-    try:
-        log.info('dongfangcaifu6')
-        dongfangcaifu6()
-    except:
-        pass
-
-    try:
-        log.info('dongfangcaifu7')
-        dongfangcaifu7()
-    except:
-        pass
+    # try:
+    #     log.info('dongfangcaifu6')
+    #     dongfangcaifu6()
+    # except:
+    #     pass
+    #
+    # try:
+    #     log.info('dongfangcaifu7')
+    #     dongfangcaifu7()
+    # except:
+    #     pass