细节优化
This commit is contained in:
parent
37136d2410
commit
37b0ea4bc7
@ -146,7 +146,7 @@ def update_agent_url(url_list, url_type):
|
|||||||
if "代理web" in context.replace(" ", "").lower():
|
if "代理web" in context.replace(" ", "").lower():
|
||||||
try:
|
try:
|
||||||
with engine.connect() as connection:
|
with engine.connect() as connection:
|
||||||
update_stmt = sql_text("UPDATE sys_platform SET url = :url WHERE nickname = :url_type")
|
update_stmt = sql_text("UPDATE sys_platform SET url = :url,update_time=NOW() WHERE nickname = :url_type")
|
||||||
connection.execute(update_stmt, {"url": url, "url_type": url_type})
|
connection.execute(update_stmt, {"url": url, "url_type": url_type})
|
||||||
connection.commit()
|
connection.commit()
|
||||||
logger.debug(f"{url_type}后台链接更新成功")
|
logger.debug(f"{url_type}后台链接更新成功")
|
||||||
|
@ -25,7 +25,6 @@ ENV RABBITMQ_USER=bot
|
|||||||
ENV RABBITMQ_PASSWORD=xiaomi@123
|
ENV RABBITMQ_PASSWORD=xiaomi@123
|
||||||
ENV RABBITMQ_HOST=mq.stupidpz.com
|
ENV RABBITMQ_HOST=mq.stupidpz.com
|
||||||
ENV RABBITMQ_PORT=5672
|
ENV RABBITMQ_PORT=5672
|
||||||
ENV TELEGRAM_BOT_TOKEN=<your_telegram_bot_token>
|
|
||||||
ENV TZ=Asia/Shanghai
|
ENV TZ=Asia/Shanghai
|
||||||
|
|
||||||
# 配置健康检查
|
# 配置健康检查
|
||||||
|
@ -150,7 +150,7 @@ def handle_login_failure(account: Account):
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
def base64_api(uname='luffy230505', pwd='qwer12345', img='', typeid=20):
|
def base64_api(uname='luffy230505', pwd='XIAOmi123', img='', typeid=20):
|
||||||
logger.info('Calling third part interfaces')
|
logger.info('Calling third part interfaces')
|
||||||
data = {
|
data = {
|
||||||
"username": uname,
|
"username": uname,
|
||||||
|
@ -11,7 +11,6 @@ rabbitmq_user = os.getenv("RABBITMQ_USER", "bot")
|
|||||||
rabbitmq_password = os.getenv("RABBITMQ_PASSWORD", "xiaomi@123")
|
rabbitmq_password = os.getenv("RABBITMQ_PASSWORD", "xiaomi@123")
|
||||||
rabbitmq_host = os.getenv("RABBITMQ_HOST", "mq.stupidpz.com")
|
rabbitmq_host = os.getenv("RABBITMQ_HOST", "mq.stupidpz.com")
|
||||||
rabbitmq_port = int(os.getenv("RABBITMQ_PORT", 5672))
|
rabbitmq_port = int(os.getenv("RABBITMQ_PORT", 5672))
|
||||||
telegram_bot_token = os.getenv("TELEGRAM_BOT_TOKEN")
|
|
||||||
|
|
||||||
# 移除默认的日志处理器
|
# 移除默认的日志处理器
|
||||||
logger.remove()
|
logger.remove()
|
||||||
@ -66,7 +65,7 @@ async def _send_message_to_user(bot_token, target_id, message, rate_limiter, ses
|
|||||||
return
|
return
|
||||||
else:
|
else:
|
||||||
logger.debug('消息发送失败,重试中...')
|
logger.debug('消息发送失败,重试中...')
|
||||||
logger.error(await response.text())
|
logger.error(f'{params},发送失败,返回值:{await response.text()}')
|
||||||
except aiohttp.ClientError as e:
|
except aiohttp.ClientError as e:
|
||||||
logger.error(f'网络异常,重试中... 错误详情: {e}')
|
logger.error(f'网络异常,重试中... 错误详情: {e}')
|
||||||
await asyncio.sleep(10)
|
await asyncio.sleep(10)
|
||||||
|
Loading…
Reference in New Issue
Block a user