update

task/spark_test.py

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