SSEClient читает только блоки данных и не останавливается в конце - PullRequest
0 голосов
/ 03 июня 2019

Я успешно настроил SSEClient .

# set credentials
my_url = 'https://my_endpoint'
h = {'Authorization': 'Bearer ' + my_token, 'environment': 'my_env'}

# execute sse client
m = SSEClient(my_url, headers=h)

# work with result set
s = ''

for i, msg in enumerate(m):
    s+=msg.data
    print(i)

Через некоторое время я получаю requests.exceptions.HTTPError: 401 Client Error: 401 for url. Я наблюдал за процессом и обнаружил, что Клиент (независимо от того, какое значение chunk_size я установил) читает данные построчно в блоках. Он читается как 1198 lines, then up to 2396 lines, 3594, 4792,...,11980 (время между перерывами составляет около 5 секунд). После 11980 он начинается снова и останавливается с error 401 сверху. Кто-нибудь, кто может помочь мне здесь? Я не знаю, почему я получаю ошибку, все работает. Похоже, у клиента проблемы с поиском конца.

Изучив полученный объект .NET, я только что увидел, что я должен получить только 1197 наборов данных. Похоже, клиент не останавливает цикл и перебирает его снова и снова.

...