broken_streaming.py

import os
import twython
import dotenv

class Streamer(twython.TwythonStreamer):

    def on_sucess(self, data):
        if 'text' in data:
            print(data['text'].encode('utf-8'))

    def on_error(self, status_code, data):
        print('error status code: {}\n{}'.format(status_code, data))

dotenv.load_dotenv('.env')
stream = Streamer(
    os.environ['API_KEY'],
    os.environ['API_SECRET'],
    os.environ['ACCESS_TOKEN'],
    os.environ['ACCESS_SECRET']
)
stream.user()