美国证券交易委员会--基本信息

comData/SEC_US/base_info_us.py

@@ -108,8 +108,8 @@ if __name__=='__main__':
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'], api_version=(2, 0, 2))
                 kafka_result = producer.send("regionInfo", json.dumps(com_dict, ensure_ascii=False).encode('utf8'))
-                print(kafka_result.get(timeout=10))
-                log.info(f'{cik}---{com_name}---基本信息采集成功')
+                log.info(kafka_result.get(timeout=10))
+                log.info(f'{cik}---{cname}---基本信息采集成功')
             except:
                 exception = 'kafka传输失败'
                 state = 0