Я успешно настроил 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 наборов данных. Похоже, клиент не останавливает цикл и перебирает его снова и снова.