Merge branch 'poll_num' into 'master'

Poll num

See merge request !40

click/views/click_fun.py

@@ -3,7 +3,7 @@ import traceback
 from libs.error import logging_exception
 import logging
 from libs.cache import redis_client
-import json
+import json, time
 from moment.views.send_email import send_email_tome
 from moment.views.process_time import get_vest_userid
 import datetime
@@ -50,10 +50,12 @@ def click(card_info):
 
         rpc_invoker = get_rpc_invoker()
         try:
+            begin = time.time()
             current_user_id = get_vest_userid(need_comment_num=1)[0]
             status = rpc_invoker['qa/irrigation/create_answer_vote'](user_id=current_user_id,
                                                                      answer_id=card_info['card_id']).unwrap()
-            logging.info('get_create_answer_vote_status:%s,card_id:%s' % (status, card_info['card_id']))
+            logging.info('get_create_answer_vote_status:%s,card_id:%s,耗时:%s' % (
+            status, card_info['card_id'], time.time() - begin))
             error = status.get('error', 1)
             if error == 0:
                 return True

comment/views/comment_fun.py

@@ -3,7 +3,7 @@ import traceback
 from libs.error import logging_exception
 import logging
 from libs.cache import redis_client
-import json
+import json, time
 from moment.views.send_email import send_email_tome
 import datetime
 from moment.views.process_time import get_vest_userid_and_comment, get_vest_userid
@@ -144,12 +144,14 @@ def comment(card_info):
             rpc_invoker = get_rpc_invoker()
 
             try:
+                begin = time.time()
                 current_user_id = get_vest_userid(need_comment_num=1)[0]
                 status = rpc_invoker['qa/irrigation/create_answer_reply'](user_id=current_user_id,
                                                                           answer_id=card_info['card_id'],
                                                                           content=card_info[
                                                                               'comment_content']).unwrap()
-                logging.info('get_create_answer_reply_status:%s,card_id:%s' % (status, card_info['card_id']))
+                logging.info('get_create_answer_reply_status:%s,card_id:%s,耗时:%s' % (
+                status, card_info['card_id'], time.time() - begin))
 
                 error = status.get('error', 1)
                 if error == 0:

follow/views/follow_fun.py

@@ -3,7 +3,7 @@ import traceback
 from libs.error import logging_exception
 import logging
 from libs.cache import redis_client
-import json
+import json, time
 from moment.views.send_email import send_email_tome
 from moment.views.process_time import get_vest_userid
 import datetime
@@ -50,11 +50,13 @@ def follow(card_info):
 
         rpc_invoker = get_rpc_invoker()
         try:
+            begin = time.time()
             current_user_id = get_vest_userid(need_comment_num=1)[0]
             status = rpc_invoker['api/irrigation/user_add_follow'](follow_user_id=current_user_id,
                                                                    followed_user_id=card_info[
                                                                        'card_user_id']).unwrap()
-            logging.info('get_user_add_follow_status:%s,card_id:%s' % (status, card_info['card_id']))
+            logging.info(
+                'get_user_add_follow_status:%s,card_id:%s，耗时:%s' % (status, card_info['card_id'], time.time() - begin))
 
             error = status.get('error', 1)
             if error == 0:

moment/views/consum.py

@@ -32,7 +32,7 @@ def kafka_consum(topic_name=None):
     try:
         while True:
             begin = time.time()
-            msg_dict = consumser_obj.poll(timeout_ms=10000, max_records=100)
+            msg_dict = consumser_obj.poll(timeout_ms=30000, max_records=100)
             for msg_value in msg_dict.values():
                 for msg in msg_value:
                     card_info = json.loads(str(msg.value, encoding="utf8"))