del log

click/views/click_fun.py

@@ -53,7 +53,6 @@ def click(card_info):
             status = rpc_invoker['qa/irrigation/create_answer_vote'](user_id=card_info['current_user_id'],
                                                                      answer_id=card_info['card_id']).unwrap()
 
-            logging.info("get_card_info:%s,create_answer_vote:%s" % (card_info, status))
             error = status.get('error', 1)
             if error == 0:
                 return True

comment/views/comment_fun.py

@@ -148,8 +148,6 @@ def comment(card_info):
                                                                           answer_id=card_info['card_id'],
                                                                           content=card_info[
                                                                               'comment_content']).unwrap()
-                logging.info("get_card_info:%s,create_answer_reply:%s" % (card_info, status))
-
                 error = status.get('error', 1)
                 if error == 0:
                     return True

follow/views/follow_fun.py

@@ -52,7 +52,6 @@ def follow(card_info):
             status = rpc_invoker['api/irrigation/user_add_follow'](follow_user_id=card_info['current_user_id'],
                                                                    followed_user_id=card_info[
                                                                        'card_user_id']).unwrap()
-            logging.info("get_card_info:%s,user_add_follow:%s" % (card_info, status))
 
             error = status.get('error', 1)
             if error == 0:

moment/views/consum.py

@@ -23,6 +23,7 @@ from moment.views.process_time import judge_offset_partition_have_consum, judge_
 import msgpack
 from kafka import TopicPartition
 
+
 def kafka_consum(topic_name=None):
     topic_name = settings.KAFKA_TOPIC_NAME
     consumser_obj = KafkaConsumer(topic_name, bootstrap_servers=settings.KAFKA_BROKER_LIST, enable_auto_commit=True,
@@ -105,7 +106,7 @@ def kafka_consum(topic_name=None):
                                                     if is_success:
                                                         auto_comment_user(card_info)
                                                     else:
-                                                        logging.info("这条数据将被paas:%s" % card_info)
+                                                        pass
 
                                             elif action_type == "click":  # 在这里去调点赞的接口
                                                 if 'have_click_number' in card_info:
@@ -118,8 +119,7 @@ def kafka_consum(topic_name=None):
                                                     if is_success:
                                                         auto_click_user(card_info)
                                                     else:
-                                                        logging.info("这条数据将被paas:%s" % card_info)
-
+                                                        pass
 
                                             elif action_type == "follow":  # 在这里去调关注的接口
                                                 if 'have_follow_number' in card_info:
@@ -132,7 +132,7 @@ def kafka_consum(topic_name=None):
                                                     if is_success:
                                                         auto_follow_user(card_info)
                                                     else:
-                                                        logging.info("这条数据将被paas:%s" % card_info)
+                                                        pass
 
                             else:  # push_time时间未到 需要等待
                                 logging.info("follow [%s,%s,%s,%s],push_time未到,需要等待" % (