mirror of
https://github.com/TriM-Organization/LiteyukiBot-TriM.git
synced 2024-12-04 03:04:45 +08:00
🐍修复我不小心给aiohttp阻塞了的问题
This commit is contained in:
parent
31dfcb98f7
commit
1300fd95d9
@ -80,22 +80,25 @@ async def update_yanlun():
|
|||||||
|
|
||||||
global yanlun_texts, yanlun_seqs
|
global yanlun_texts, yanlun_seqs
|
||||||
|
|
||||||
|
nonebot.logger.info("正在获取言·论信息")
|
||||||
try:
|
try:
|
||||||
async with aiohttp.ClientSession() as client:
|
async with aiohttp.ClientSession() as client:
|
||||||
resp = await client.get(yanlun_path)
|
resp = await client.get(yanlun_path)
|
||||||
yanlun_texts = (await resp.text()).strip("\n").split("\n")
|
yanlun_texts = (await resp.text()).strip("\n").split("\n")
|
||||||
except (ConnectionError, aiohttp.ClientError, aiohttp.WebSocketError) as E:
|
except (ConnectionError, aiohttp.ClientError, aiohttp.WebSocketError) as err:
|
||||||
nonebot.logger.warning(f"读取言·论信息发生 客户端或通道 错误:\n{E}")
|
nonebot.logger.warning("读取言·论信息发生 客户端或通道 错误:\n{}".format(err))
|
||||||
yanlun_texts = ["以梦想为驱使 创造属于自己的未来"]
|
yanlun_texts = ["以梦想为驱使 创造属于自己的未来"]
|
||||||
# noinspection PyBroadException
|
# noinspection PyBroadException
|
||||||
except BaseException as E:
|
except BaseException as err:
|
||||||
nonebot.logger.warning(f"读取言·论信息发生 未知 错误:\n{E}")
|
nonebot.logger.warning("读取言·论信息发生 未知 错误:\n{}".format(err))
|
||||||
yanlun_texts = ["灵光焕发 深艺献心"]
|
yanlun_texts = ["灵光焕发 深艺献心"]
|
||||||
|
|
||||||
yanlun_seqs = yanlun_texts.copy()
|
yanlun_seqs = yanlun_texts.copy()
|
||||||
random.shuffle(yanlun_seqs)
|
random.shuffle(yanlun_seqs)
|
||||||
|
|
||||||
return len(yanlun_texts)
|
nonebot.logger.success("成功取得 言·论 {} 条".format(res := len(yanlun_texts)))
|
||||||
|
|
||||||
|
return res
|
||||||
|
|
||||||
|
|
||||||
@nonebot.get_driver().on_startup
|
@nonebot.get_driver().on_startup
|
||||||
@ -121,9 +124,7 @@ async def _():
|
|||||||
"Happy Birthday, ElapsingDreams~!",
|
"Happy Birthday, ElapsingDreams~!",
|
||||||
]
|
]
|
||||||
else:
|
else:
|
||||||
|
await update_yanlun()
|
||||||
nonebot.logger.info("正在获取言·论信息")
|
|
||||||
nonebot.logger.success("成功取得 言·论 {} 条".format(await update_yanlun()))
|
|
||||||
|
|
||||||
|
|
||||||
def random_yanlun_text() -> str:
|
def random_yanlun_text() -> str:
|
||||||
|
Loading…
Reference in New Issue
Block a user