consumer_secret = ''
access_key = ''
access_secret = ''
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_key, access_secret)
api = tweepy.API(auth)


class CustomStreamListener(tweepy.StreamListener):

    def __init__(self, api):
        self.api = api
super(tweepy.StreamListener, self).__init__()
self.db = pymongo.MongoClient().test

def on_data(self, tweet):
    self.db.tweets.insert(json.loads(tweet))

def on_error(self, status_code):
    return True

def on_timeout(self):
    return True
sapi = tweepy.streaming.Stream(auth, CustomStreamListener(api))
sapi.filter(track=['Gandolfini'])
Как я могу использовать твиты из потокового API Twitter и хранить их в mongodb