Sfoglia il codice sorgente

checkVideoStatusDaily.py

修改任务,每次执行任务的时候启动数据库连接,每次执行完成的时候关闭数据库连接
罗俊辉 7 mesi fa
parent
commit
60c61fe8c5
1 ha cambiato i file con 13 aggiunte e 1 eliminazioni
  1. 13 1
      checkVideoStatusDaily.py

+ 13 - 1
checkVideoStatusDaily.py

@@ -102,9 +102,21 @@ class VideoStatusManager(object):
         print("total", len(video_id_list))
         print("bad_total", bad_count)
 
+    @classmethod
+    def closeConnection(cls):
+        """
+        关闭连接
+        :return:
+        """
+        cls.db_client.close()
+
 
 if __name__ == '__main__':
-    VM = VideoStatusManager()
     while True:
+        """
+        每次任务重新连接数据库,处理完之后关闭数据库连接
+        """
+        VM = VideoStatusManager()
         VM.deal()
+        VM.closeConnection()
         time.sleep(10 * 60)