Twitter Streaming Example

INSTALL

pip install requests requests_oauthlib

swtrains.py

from requests_oauthlib import OAuth1Session
import json
import requests

CONSUMER_KEY = "..."
CONSUMER_SECRET = "..."

ACCESS_TOKEN = "..."
TOKEN_SECRET = "..."

STREAM_URL = "https://stream.twitter.com/1.1/statuses/filter.json"

def get_client():
    return OAuth1Session(CONSUMER_KEY,
        client_secret=CONSUMER_SECRET,
        resource_owner_key=ACCESS_TOKEN,
        resource_owner_secret=TOKEN_SECRET
    )

def get_response(client, **filter_data):
    return client.post(
        STREAM_URL,
        data=filter_data,
        stream=True
    )

def print_lines(r):
    for line in r.iter_lines():
        if line: # filter out keep-alive new lines
            print json.loads(line)


if __name__ == "__main__":
    client = get_client()
    r = get_response(client, track="@sw_trains")
    print_lines(r)