update redis client
This commit is contained in:
parent
8d5231e2a4
commit
72a67a7bf0
|
@ -4,7 +4,7 @@
|
||||||
# @version:
|
# @version:
|
||||||
import asyncio
|
import asyncio
|
||||||
import json
|
import json
|
||||||
from loguru import logger
|
from urllib.parse import quote_plus
|
||||||
import redis.asyncio as redis
|
import redis.asyncio as redis
|
||||||
|
|
||||||
from core.db import *
|
from core.db import *
|
||||||
|
@ -33,7 +33,7 @@ async def get_redis_pool():
|
||||||
socket.TCP_KEEPINTVL: 10,
|
socket.TCP_KEEPINTVL: 10,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
redis_con = await redis.from_url(f"redis://:{REDIS_PASSWORD}@{REDIS_IP}:{REDIS_PORT}", encoding="utf-8",
|
redis_con = await redis.from_url(f"redis://:{quote_plus(REDIS_PASSWORD)}@{REDIS_IP}:{REDIS_PORT}", encoding="utf-8",
|
||||||
decode_responses=True, **keep_alive_config)
|
decode_responses=True, **keep_alive_config)
|
||||||
try:
|
try:
|
||||||
yield redis_con
|
yield redis_con
|
||||||
|
|
Loading…
Reference in New Issue