Я думаю, мне нужно изменить конфигурацию Redis по умолчанию, но я не знаю, какие параметры конфигурации мне нужно изменить.
Я не изменил параметры конфигурации Redis по умолчанию. Я хочу использовать xread block 0 streams k $
блокировать и ждать поступления новых сообщений, но это вызывает исключение.
from redis import Redis
db = Redis(host='192.168.1.24', port=32111, db=0)
print(db.keys('*'))
print(db.config_get('*'))
k = db.execute_command('xread block 0 streams k $')
Ожидается, что xread block 0 streams k
будет блокироваться постоянно до получения нового сообщения.Фактическое сообщение об ошибке:
Traceback (most recent call last):
File "/home/server/.local/lib/python3.5/site-packages/redis/connection.py", line 398, in read_response
raise socket.error(SERVER_CLOSED_CONNECTION_ERROR)
OSError: Connection closed by server.
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/home/server/PycharmProjects/test/stream_test.py", line 7, in <module>
k = db.execute_command('xread block 0 streams k $')
File "/home/server/.local/lib/python3.5/site-packages/redis/client.py", line 775, in execute_command
return self.parse_response(connection, command_name, **options)
File "/home/server/.local/lib/python3.5/site-packages/redis/client.py", line 789, in parse_response
response = connection.read_response()
File "/home/server/.local/lib/python3.5/site-packages/redis/connection.py", line 637, in read_response
response = self._parser.read_response()
File "/home/server/.local/lib/python3.5/site-packages/redis/connection.py", line 409, in read_response
(e.args,))
redis.exceptions.ConnectionError: Error while reading from socket: ('Connection closed by server.',)