def read_stream(app_name, auth_token):
while True:
stream_url = yield from get_stream_url(app_name, auth_token)
print('Reading stream: %s' % stream_url)
log = b''
with aiohttp.ClientSession() as session:
response = yield from session.get(stream_url)
while True:
try:
chunk = yield from response.content.read(1)
except aiohttp.ServerDisconnectedError:
break
if not chunk:
break
if chunk == b'\n':
try:
yield from write_to_queue(log)
except ValueError as e:
print(str(e))
log = b''
else:
log += chunk
评论列表
文章目录