"xread block 0 streams mystream $", но redis.exceptions.ConnectionError - PullRequest
0 голосов
/ 14 мая 2019

Я думаю, мне нужно изменить конфигурацию 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.',)

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...