old_contents: from streamsx.topology.topology import *
  import streamsx.topology.context
  import sys
  import tweets
  
  #
  # Continually stream tweets that contain
  # the terms passed on the command line.
  #
  # python3 app.py Food GlutenFree
  #
  def main():
    terms = sys.argv[1:]
    topo = Topology("TweetsUsingTweepy")
  
    # Event based source stream
    # Each tuple is a dictionary containing
    # the full tweet (converted from JSON)
    ts = topo.source(tweets.tweets(terms))
    
    # get the text of the tweet
    ts = ts.transform(tweets.text)
  
    # just print it
    ts.print()
  
    streamsx.topology.context.submit("DISTRIBUTED", topo.graph)
  
  if __name__ == '__main__':
      main()
  
new_contents: from streamsx.topology.topology import *
  import streamsx.topology.context
  import sys
  import tweets
  
  #
  # Continually stream tweets that contain
  # the terms passed on the command line.
  #
  # python3 app.py Food GlutenFree
  #
  #
  # Requires tweepy to be installed
  #
  # pip3 install tweepy
  #
  # http://www.tweepy.org/
  #
  # You must create Twitter application authentication tokens
  # and set them in the mykeys.py module.
  # Note this is only intended as a simple sample,
  #
  
  def main():
    terms = sys.argv[1:]
    topo = Topology("TweetsUsingTweepy")
  
    # Event based source stream
    # Each tuple is a dictionary containing
    # the full tweet (converted from JSON)
    ts = topo.source(tweets.tweets(terms))
    
    # get the text of the tweet
    ts = ts.transform(tweets.text)
  
    # just print it
    ts.print()
  
    streamsx.topology.context.submit("DISTRIBUTED", topo.graph)
  
  if __name__ == '__main__':
      main()
  
subject: Add some info about tweepy