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

diaryQueueUpdate.py

@@ -130,8 +130,9 @@ 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)
 
-    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()
     score_list = list(result)