fix: Catch ServerDisconnectedError in dynamic push
This commit is contained in:
@@ -1,7 +1,7 @@
|
|||||||
import asyncio
|
import asyncio
|
||||||
import time
|
import time
|
||||||
|
|
||||||
from aiohttp import ClientOSError
|
from aiohttp import ClientOSError, ServerDisconnectedError
|
||||||
from loguru import logger
|
from loguru import logger
|
||||||
|
|
||||||
from .datasource import DataSource
|
from .datasource import DataSource
|
||||||
@@ -33,6 +33,8 @@ async def dynamic_spider(datasource: DataSource):
|
|||||||
logger.error(f"动态推送任务抓取最新动态异常, HTTP 错误码: {ex.code} ({ex.msg})")
|
logger.error(f"动态推送任务抓取最新动态异常, HTTP 错误码: {ex.code} ({ex.msg})")
|
||||||
except ClientOSError:
|
except ClientOSError:
|
||||||
continue
|
continue
|
||||||
|
except ServerDisconnectedError:
|
||||||
|
continue
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
logger.exception("动态推送任务抓取最新动态异常", ex)
|
logger.exception("动态推送任务抓取最新动态异常", ex)
|
||||||
continue
|
continue
|
||||||
|
|||||||
Reference in New Issue
Block a user