jsdio/ips_etl
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Обработка разрыва соединения

Browse Source
This commit is contained in:
Григорич 2023-06-05 17:33:45 +03:00
parent 71c630bfde
commit 361afad6fe
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/extractor.py
View File

@ -19,7 +19,8 @@ class ApiExtractor:
self.headers = {"Authorization-Token": self.api_config.token} self.headers = {"Authorization-Token": self.api_config.token}
self.fields = ["ID", "IBLOCK_ID", "NAME", "CODE", "SECTION_ID"] self.fields = ["ID", "IBLOCK_ID", "NAME", "CODE", "SECTION_ID"]
@backoff.on_exception(backoff.expo, (aiohttp.ClientResponseError, aiohttp.ClientConnectorError), base=2, factor=1, @backoff.on_exception(backoff.expo, (aiohttp.ClientResponseError, aiohttp.ClientConnectorError,
aiohttp.ServerDisconnectedError), base=2, factor=1,
max_value=5, max_tries=None) max_value=5, max_tries=None)
async def get_extract_data(self, state: State, iblock_id: int, fields: list = None, **kwargs) -> list[Abitr]: async def get_extract_data(self, state: State, iblock_id: int, fields: list = None, **kwargs) -> list[Abitr]: