开启日志用于调试

ops/ad_produce.py

@@ -165,8 +165,11 @@ def produce_task():
                 except Exception:
                     log.error(f"split {line} failed!", exc_info=True)
                     run_status = 0
+
         log.info(f"produce {len(all)} 2 redis!")  #log.info("end produce cache!")
         my_redis.set("ad_produce", run_status)
         now = datetime.datetime.now()
         timestamp = int(datetime.datetime.timestamp(now))
         my_redis.set("ad_produce_time", timestamp)
+    del data
+    del all