stream.py 文件源码

def main(argv):
    print(argv)
    if len(argv) < 2:
        sys.stderr.write("Usage: %s <searchKeyword>" % (argv[0],))
        return 1

    l = StdOutListener(config.es_configuration)
    auth = OAuthHandler(config.consumer_key, config.consumer_secret)
    auth.set_access_token(config.access_token, config.access_token_secret)
    stream = Stream(auth, l)
    print "Stream started\n"
    stream.filter(track=[argv[1]])
    print "Stream ended!\n"