sseclient_streaming_sse_events_with_requests_and_urllib3.py

1import json
2import pprint
3import sseclient
4
5def with_requests(url):
6    """Get a streaming response for the given event source URL."""
7    import requests
8    response = requests.get(url, stream=True)
9    client = sseclient.SSEClient(response)
10    for event in client.events():
11        pprint.pprint(json.loads(event.data))
12
13def with_urllib3(url):
14    """Get a streaming response for the given event source URL."""
15    import urllib3
16    http = urllib3.PoolManager()
17    response = http.request('GET', url, preload_content=False)
18    client = sseclient.SSEClient(response)
19    for event in client.events():
20        pprint.pprint(json.loads(event.data))