Gnip Powertrackreplay

gnip_powertrackreplay.hpy

#!/bin/sh
"exec" "twxec" "-e" "replay_stream()" "$0" "$@"

from trickle.gnip import PowerTrackReplayStream
import datetime as dt

user = {{string User_Name}}
account = {{string Account_Name}}
password = {{password Account_Password}}
config = {{string GNIP_Configuration}}
end_date = dt.datetime.utcnow() - dt.timedelta(hours=1)
start_date = end_date - dt.timedelta(days=5)


def replay_stream():
    with PowerTrackReplayStream(user, password, account, config, start_date, end_date) as stream:
        for tweet in stream:
            yield tweet