In [1]:

    

import tweepy


    

In [2]:

    

from tweepy import OAuthHandler


    

In [3]:

    

consumer_key = '#'
consumer_secret = '#'
access_token = '#'
access_secret = '#'


    

In [4]:

    

auth = OAuthHandler(consumer_key, consumer_secret)


    

In [5]:

    

auth.set_access_token(access_token, access_secret)


    

In [6]:

    

api = tweepy.API(auth)


    

In [7]:

    

from tweepy import Stream
from tweepy.streaming import StreamListener


    

In [8]:

    

import socket
import json


    

In [9]:

    

class tweetsListener(StreamListener):
    def _init_(self,csocket):
        self.client_socket=csocket
    def on_data(self,data):
        try:
            msg = json.loads(data)
            print(msg['text'].encode('utf-8'))
            self.client_socket.send(msg['text'].encode('utf-8'))
            return True
        except BaseException as e:
            print("Error on data:%s" %str(e))
        return True
    def on_error(self,status):
        print(status)
        return True


    

In [10]:

    

def sendData(c_socket):
    twitter_stream = Stream(auth,tweetsListener(c_socket))
    twitter_stream.filter(track=['trump'])


    

In [11]:

    

s = socket.socket()


    

In [12]:

    

host = "172.31.38.183"


    

In [13]:

    

port = 3307


    

In [14]:

    

s.bind((host,port))


    

In [15]:

    

print("listening on the port %s" % str(port))


    

    




listening on the port 3307

In [16]:

    

s.listen(5)


    

In [ ]:

    

c, addr = s.accept()


    

In [ ]:

    

print("Received Request from :" +str( addr ))


    

In [ ]:

    

sendData(c)


    

In [ ]: