update spider expired rate

utils/mongo.py

@@ -108,7 +108,8 @@ class MongoOperator:
                 print(plat, expired, total)
         if msgs:
             ts = int(time.time())
-            mysql_db.insert_expired_data(ts, json.dumps(expired_dict))
+            for k, v in expired_dict.items():
+                mysql_db.insert_expired_data(ts, k, v)
             return msg
         else:
             return

utils/mysql.py

@@ -59,10 +59,10 @@ class MySqlOperator:
             cursor.execute(sql, (s, u))
             self.db.commit()
 
-    def insert_expired_data(self,time_stamp,platform_data):
+    def insert_expired_data(self, time_stamp, platform, expired_rate):
         with self.db.cursor() as cursor:
             sql = """
-                         INSERT INTO lie_spider_expired_rate(time_stamp, platform_data) VALUES (%s, %s)
+                         INSERT INTO lie_spider_expired_rate(time_stamp, platform,expired_rate) VALUES (%s,%s,%s)
                          """
-            cursor.execute(sql,(time_stamp,platform_data))
-            self.db.commit()
\ No newline at end of file
+            cursor.execute(sql, (time_stamp, platform, expired_rate))
+            self.db.commit()