Twitter mongo example

requirements.txt

pymongo
twython

twitter.py

# coding: utf-8

CONSUMER_KEY = ''
CONSUMER_SECRET = ''
ACESS_TOKEN = ''
ACCESS_TOKEN_SECRET = ''

from twython import TwythonStreamer

from pymongo import MongoClient

db = MongoClient('localhost').twitter

class MyStreamer(TwythonStreamer):
    def on_success(self, data):
        db.my_db.insert(data)

    def on_error(self, status_code, data):
        print status_code

stream = MyStreamer(CONSUMER_KEY, CONSUMER_SECRET,
                    ACESS_TOKEN, ACCESS_TOKEN_SECRET)

stream.statuses.filter(track='#hashtag')