ramforth/pytchat-fork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use logger when errors occur

Browse Source
This commit is contained in:
taizan-hokuto
2019-11-20 23:59:16 +09:00
parent 817fed9d1d
commit 0e060bf998
4 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pytchat/core_async/replaychat.py
View File

@@ -168,10 +168,10 @@ class ReplayChatAsync:
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
while(continuation and self._is_alive): while(continuation and self._is_alive):
if self._pauser.empty(): if self._pauser.empty():
#pauseが呼ばれて_pauserが空状態のときは一時停止する #pause
await self._pauser.get() await self._pauser.get()
#resumeが呼ばれて_pauserにitemが入ったら再開する #resume
#直後に_pauserにitem(None)を入れてブロックを防ぐ #prohibit from blockng by putting None into _pauser.
self._pauser.put_nowait(None) self._pauser.put_nowait(None)
livechat_json = (await livechat_json = (await
self._get_livechat_json(continuation, session, headers) self._get_livechat_json(continuation, session, headers)

6
pytchat/core_multithread/replaychat.py
View File

@@ -162,10 +162,10 @@ class ReplayChat:
with requests.Session() as session: with requests.Session() as session:
while(continuation and self._is_alive): while(continuation and self._is_alive):
if self._pauser.empty(): if self._pauser.empty():
#pauseが呼ばれて_pauserが空状態のときは一時停止する #pause
self._pauser.get() self._pauser.get()
#resumeが呼ばれて_pauserにitemが入ったら再開する #resume
#直後に_pauserにitem(None)を入れてブロックを防ぐ #prohibit from blockng by putting None into _pauser.
self._pauser.put_nowait(None) self._pauser.put_nowait(None)
livechat_json = ( livechat_json = (
self._get_livechat_json(continuation, session, headers) self._get_livechat_json(continuation, session, headers)

2
pytchat/mylogger.py
View File

@@ -17,7 +17,7 @@ def get_logger(modname,mode=logging.DEBUG):
logger.addHandler(handler1) logger.addHandler(handler1)
#create handler2 for recording log file #create handler2 for recording log file
if mode <= logging.DEBUG: if mode <= logging.DEBUG:
handler2 = logging.FileHandler(filename="log.txt") handler2 = logging.FileHandler(filename="log.txt", encoding='utf-8')
handler2.setLevel(logging.ERROR) handler2.setLevel(logging.ERROR)
handler2.setFormatter(my_formatter) handler2.setFormatter(my_formatter)

7
pytchat/processors/default/processor.py
View File

@@ -4,7 +4,9 @@ from .renderer.textmessage import LiveChatTextMessageRenderer
from .renderer.paidmessage import LiveChatPaidMessageRenderer from .renderer.paidmessage import LiveChatPaidMessageRenderer
from .renderer.paidsticker import LiveChatPaidStickerRenderer from .renderer.paidsticker import LiveChatPaidStickerRenderer
from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer
from ... import config
from ... import mylogger
logger = mylogger.get_logger(__name__,mode=config.LOGGER_MODE)
class Chatdata: class Chatdata:
def __init__(self,chatlist:list, timeout:float): def __init__(self,chatlist:list, timeout:float):
@@ -60,8 +62,7 @@ class DefaultProcessor:
renderer.get_snippet() renderer.get_snippet()
renderer.get_authordetails() renderer.get_authordetails()
except (KeyError,TypeError,AttributeError) as e: except (KeyError,TypeError,AttributeError) as e:
print(f"------{str(type(e))}-{str(e)}----------") logger.error(f"{str(type(e))}-{str(e)} sitem:{str(sitem)}")
print(sitem)
return None return None
return renderer return renderer