开启日志用于调试

ops/ad_produce.py

@@ -65,6 +65,7 @@ def sadd_adkey(key, line):
 
 def produce_task():
     # log.info("start produce cache !")
+    mydb1 = MysqlBase(**mysql_promotion_config)
     now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S")
     run_status = 1
     all = []
@@ -95,7 +96,7 @@ def produce_task():
         """
 
     log.info(f"select sql= {get_data_sql}")
-    data = mydb.query(get_data_sql)
+    data = mydb1.query(get_data_sql)
     log.info(f"data = {data}")
     if data:
         for line in data: