添加日志

moment/views/consum.py

@@ -54,11 +54,14 @@ def kafka_consum(topic_name=None):
                                 if card_info['action_type'] == "comment":
                                     auto_comment_user(card_info, after_day=True)
 
+                                    logging.info("auto_comment_user子函数消费处理耗时:%f" % (time.time() - begin))
                                 elif card_info['action_type'] == "click":
                                     auto_click_user(card_info, after_day=True)
+                                    logging.info("auto_click_user子函数消费处理耗时:%f" % (time.time() - begin))
 
                                 elif card_info['action_type'] == "follow":
                                     auto_follow_user(card_info, after_day=True)
+                                    logging.info("auto_follow_user子函数消费处理耗时:%f" % (time.time() - begin))
 
                                 else:
                                     pass
@@ -89,7 +92,13 @@ def kafka_consum(topic_name=None):
                                             if 'have_comment_number' in card_info and \
                                                     card_info['have_comment_number'] < 20:
                                                 card_info["have_comment_number"] += 1
+                                                logging.info("当前卡片ID:%s,comment1子函数消费处理耗时:%f" % (
+                                                    card_info['card_id'], time.time() - begin))
+
                                                 is_success = comment(card_info)
+
+                                                logging.info("当前卡片ID:%s,comment2子函数消费处理耗时:%f" % (
+                                                    card_info['card_id'], time.time() - begin))
                                                 logging.info("comment [%s,%s,%s,%s],当前ID:%s，下发状状态:%s" % (
                                                     str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key),
                                                     card_info["card_id"], is_success))
@@ -100,7 +109,13 @@ def kafka_consum(topic_name=None):
                                         elif action_type == "click":  # 在这里去调点赞的接口
                                             if 'have_click_number' in card_info and card_info['have_click_number'] < 20:
                                                 card_info["have_click_number"] += 1
+                                                logging.info("当前卡片ID:%s,click1子函数消费处理耗时:%f" % (
+                                                    card_info["card_id"], time.time() - begin))
+
                                                 is_success = click(card_info)
+                                                logging.info("当前卡片ID:%s,click2子函数消费处理耗时:%f" % (
+                                                    card_info["card_id"], time.time() - begin))
+
                                                 logging.info("click [%s,%s,%s,%s],当前ID:%s，下发状状态:%s" % (
                                                     str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key),
                                                     card_info["card_id"], is_success))
@@ -112,7 +127,14 @@ def kafka_consum(topic_name=None):
                                             if 'have_follow_number' in card_info and \
                                                     card_info['have_follow_number'] < 20:
                                                 card_info["have_follow_number"] += 1
+                                            logging.info(
+                                                "当前卡片ID:%s,当前卡片ID:%s,follow1子函数消费处理耗时:%f" % (
+                                                    card_info["card_id"], time.time() - begin))
+
                                             is_success = follow(card_info)
+                                            logging.info(
+                                                "当前卡片ID:%s,当前卡片ID:%s,follow2子函数消费处理耗时:%f" % (
+                                                    card_info["card_id"], time.time() - begin))
                                             logging.info("follow [%s,%s,%s,%s],当前ID:%s，下发状状态:%s" % (
                                                 str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key),
                                                 card_info["card_id"], is_success))