update

task/spark_test.py

@@ -106,9 +106,10 @@ SELECT *  FROM online.bl_hdfs_maidian_updates
     res_list = []
     for res in sql_res:
         print(res)
-        query = res.params["query"]
-        card_name = res.params["card_name"]
-        card_id = res.params["card_id"]
+        res_json = json.loads(res.params)
+        query = res_json["query"]
+        card_name = res_json["card_name"]
+        card_id = res_json["card_id"]
         user_id = res.user_id
         time_str = res.time_str
         page_name = res.page_name