Skip to content

V
vest
Commit abfa6540 authored by lixiaofang's avatar lixiaofang
Browse files
Options

add

parent 39f3172a
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 6 deletions
moment/views/consum.py
View file @ abfa6540
......@@ -115,8 +115,8 @@ def kafka_consum(topic_name=None):
logging.info("当前卡片ID:%s,comment2子函数消费处理耗时:%f" % (
card_info['card_id'], time.time() - begin))
# 调完接口后需要再次去拿新的push_time的时间
if is_success:
auto_comment_user(card_info)
if is_success:
auto_comment_user(card_info)
elif action_type == "click": # 在这里去调点赞的接口
if 'have_click_number' in card_info:
......@@ -131,8 +131,8 @@ def kafka_consum(topic_name=None):
logging.info("当前卡片ID:%s,click2子函数消费处理耗时:%f" % (
card_info["card_id"], time.time() - begin))
if is_success:
auto_click_user(card_info)
if is_success:
auto_click_user(card_info)
elif action_type == "follow": # 在这里去调关注的接口
if 'have_follow_number' in card_info:
......@@ -147,8 +147,8 @@ def kafka_consum(topic_name=None):
str(msg.topic), str(msg.partition), str(msg.offset),
str(msg.key),
card_info["card_id"], is_success))
if is_success:
auto_follow_user(card_info)
if is_success:
auto_follow_user(card_info)
else: # push_time时间未到 需要等待
logging.info("follow [%s,%s,%s,%s],push_time未到,需要等待" % (
str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key)))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment