mirror of
https://github.com/eternnoir/pyTelegramBotAPI.git
synced 2023-08-10 21:12:57 +03:00
@@ -3,11 +3,15 @@ import json
|
|||||||
|
|
||||||
|
|
||||||
redis_installed = True
|
redis_installed = True
|
||||||
|
aioredis_version = None
|
||||||
try:
|
try:
|
||||||
import aioredis
|
import aioredis
|
||||||
|
aioredis_version = tuple(map(int, aioredis.__version__.split(".")[0]))
|
||||||
except ImportError:
|
except ImportError:
|
||||||
try:
|
try:
|
||||||
|
import redis
|
||||||
from redis import asyncio as aioredis
|
from redis import asyncio as aioredis
|
||||||
|
aioredis_version = tuple(map(int, redis.__version__.split(".")[0]))
|
||||||
except ImportError:
|
except ImportError:
|
||||||
redis_installed = False
|
redis_installed = False
|
||||||
|
|
||||||
@@ -24,7 +28,6 @@ class StateRedisStorage(StateStorageBase):
|
|||||||
raise ImportError('AioRedis is not installed. Install it via "pip install aioredis"')
|
raise ImportError('AioRedis is not installed. Install it via "pip install aioredis"')
|
||||||
|
|
||||||
|
|
||||||
aioredis_version = tuple(map(int, aioredis.__version__.split(".")[0]))
|
|
||||||
if aioredis_version < (2,):
|
if aioredis_version < (2,):
|
||||||
raise ImportError('Invalid aioredis version. Aioredis version should be >= 2.0.0')
|
raise ImportError('Invalid aioredis version. Aioredis version should be >= 2.0.0')
|
||||||
self.redis = aioredis.Redis(host=host, port=port, db=db, password=password)
|
self.redis = aioredis.Redis(host=host, port=port, db=db, password=password)
|
||||||
|
|||||||
Reference in New Issue
Block a user