update

task/tractate_analysis_in_7000.py

@@ -273,7 +273,7 @@ for res in sql_res:
     if cl_id in device_id_dict:
         print("has device")
         card_id = res.card_id
-        if card_id not in card_id_list:continue
+        if str(card_id) not in card_id_list:continue
         print("has card_id")
         session_pv = res.session_pv
         # card_id_set.update(card_id)

utils/func_from_es_get_article.py

@@ -344,7 +344,7 @@ def get_user_post_from_mysql(sql):
     sql_res = con_sql_doris_prod(sql)
     for card_id in sql_res:
         # print(card_id)
-        card_id_list.append(card_id)
+        card_id_list.append(str(card_id))
         es_res = get_tractate_tags_from_es(card_id[0])
         for position in es_res["_source"]["second_demands"]:
             if position in second_demands_count_dict:
@@ -356,4 +356,5 @@ def get_user_post_from_mysql(sql):
                 tags_v3_count_dict[tag] += 1
             else:
                 tags_v3_count_dict[tag] = 1
+    print(card_id_list)
     return second_demands_count_dict, tags_v3_count_dict, card_id_list