diff --git a/bi/vas_yoy_flow.py b/bi/vas_yoy_flow.py
index 3594834..baf8bf0 100644
--- a/bi/vas_yoy_flow.py
+++ b/bi/vas_yoy_flow.py
@@ -33,8 +33,9 @@ class S:
         return 0
 
     def insert_flow(self, ptime, flow):
-        sql = '''insert into vas_yoy_flow (ptime, flow) values ({}, {})'''.format(ptime, flow)
-        return self.mysql_db_bi.exec(sql, ())
+        sql = '''insert into vas_yoy_flow (ptime, flow) values (%s,%s)'''
+        print(sql)
+        return self.mysql_db_bi.exec(sql, (ptime, flow))
 
     def proc(self):
         time_now = int(time.time())