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()
|
