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()