增加批量从数据库查询数据

diaryQueueUpdate.py

@@ -128,12 +128,12 @@ def merge_score(x_list, score_df):
     cursor = db.cursor()
 
     # 去除diary_id 前面的"diary|"
-    x_list = list(map(lambda x:x[6:],x_list))
+    x_list = tuple(list(map(lambda x:x[6:],x_list)))
     start = time.time()
     print(x_list[:10])
     print(x_list)
     # TODO 把id也取下来，这样可以解决分数不匹配的问题
-    sql = "select score from biz_feed_diary_score where diary_id in '{}';".format(tuple(x_list))
+    sql = "select score from biz_feed_diary_score where diary_id in {};".format(x_list)
     cursor.execute(sql)
     result = cursor.fetchall()
     print("获取成功")