import time import logging from auto_media_publisher.downloader.fetcher_dajiala import FetcherDajiala from auto_media_publisher.downloader.downloader_dajiala import DownloaderDajiala from auto_media_publisher.utils.logger import get_logger def main(): logger = get_logger("dajiala_test","admin") try: # 启动 Fetcher 线程(抓 top15 链接,每小时) #fetcher_thread = FetcherDajiala() #fetcher_thread.run() # 启动 Downloader 线程(持续下载未完成链接) downloader_thread = DownloaderDajiala() downloader_thread.run() except KeyboardInterrupt: logging.warning("检测到 Ctrl+C,正在停止线程...") if __name__ == "__main__": main()