Streaming API Client¶
Stream Listener¶
Create a StreamListener and to handle streaming data.
from accern import Stream
myStreamListener = StreamListener()
Override the on_data
function if you want to handle the data yourself.
By default, it returns the raw data.
class MyStreamListener(StreamListener):
def on_data(self, data):
df = json.loads(data), orient='columns')
print (df.head())
Authenticate Stream Client¶
from accern import StreamClient
token = 'YOUR TOKEN'
stream = StreamClient(myStreamListener, token)
Filter and select with schema¶
from accern import StreamClient, StreamListener
schema = {
'select': [
{
'field': 'entity_ticker',
'name': 'ticker'
},
{
'field': 'harvested_at',
'name': 'hour'
}
],
'filters': {
'entity_ticker': [
'AAPL', 'AMZN'
]
}
}
stream = StreamClient(MyStreamListener(), token, schema)
stream.performs()