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

diaryQueueUpdate.py

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