修改action_type

moment/views/consum.py

@@ -26,13 +26,13 @@ def kafka_consum(topic_name=None):
 
     try:
         while True:
-            msg_dict = consumser_obj.poll(timeout_ms=100, max_records=100)
+            msg_dict = consumser_obj.poll(timeout_ms=100, max_records=50)
 
             for msg_key in msg_dict:
                 consume_msg = msg_dict[msg_key]
                 for msg in consume_msg:
                     card_info = json.loads(msg.value)
-                    if card_info['card_type'] == "auto_vest":
+                    if card_info['card_type'] == "auto_vest123":
                         logging.info("+++++++++++++++++++++++++新的数据进来了+++++++++++++++++++++++")
                         logging.info("get card_info:%s" % card_info)
                         # 代表当天数据

moment/views/irrigation.py

@@ -30,7 +30,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
         if flag == True:
             comment_msg_dict = {
                 "card_id": card_id,
-                "card_type": "auto_vest",
+                "card_type": "auto_vest123",
                 "create_time": create_time,
                 "content_level": content_level,
                 "tag_names": tag_names,
@@ -44,7 +44,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
 
         follow_msg_dict = {
             "card_id": card_id,
-            "card_type": "auto_vest",
+            "card_type": "auto_vest123",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,
@@ -58,7 +58,7 @@ def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time=""
 
         click_msg_dict = {
             "card_id": card_id,
-            "card_type": "auto_vest",
+            "card_type": "auto_vest123",
             "create_time": create_time,
             "content_level": content_level,
             "tag_names": tag_names,