Add files via upload

Author: purinpiwat

demo1.py

@@ -0,0 +1,20 @@
+from twythonxx import twit #ใช้เรียกcalss  จากไฟล twythonxx
+
+e=twit() #ทำการประกาศตัวแปร eเป็นobjของ class twit 
+#-----------------------------------------------
+#e.post("testtest")
+#ใช้สำหรับโพสโดยแก้ค่าในวงเล็บให้เป็นข้อความตามที่ต้องการโพส โดยมีลิมิตอยู่ที่300ครั้ง/3ชม
+#-----------------------------------------------
+#data=e.search("#lisa")
+#ใช้สำหรับค้นหาโดยแก้ค่าในวงเล็บให้เป็นข้อความที่ต้องหารค้นหา โดยมีลิมิตอยู่ที่180 ครั้ง/15นาที
+#ค่าที่ได้จะออกมาในรูปของlistของแต่ล่ะทวิตซึ่งแต่ล่ะทวิตจะเป็น dict ที่ประกอบด้วยสมาชิกดังนี้ 'screen_name','id_user','tweet_when','tweet_id','text'
+#-----------------------------------------------
+#ใช้สำหรับค้นหาแบบที่ต้องการกำหนดรายละเอียดการค้นหาโดยจะให้ผลเป็น listที่ประกอบขึ้นจากdictโดยแต่ล่ะdictแทนทวิตแต่ล่ะข้อความที่ค้นเจอ
+#x={'count' : 5}#ตัวแปรสำหรับระบุรายละเอียดการค้นหาประกอบด้วย 'result_type' 'lang' 'count' 'until'
+#data=e.search2("#lisa",'screen_name','tweet_id',**x) #สามารถระบุประเภทข้อมูลที่ต้องการได้โดยใช้ all หากต้องการทุกค่า ข้อมูลที่สามารถระบุได้มีดังนี้ 'screen_name','id_user','tweet_when','tweet_id','text'
+#-----------------------------------------------
+#e.stream('#lisa')#คำสั่งนี้จะใช้สำหรับติดตามแทกที่ต้องการโดยจะแสดงผลทวิตใหม่ทุกรั้งทีมีการทวิตแทกนี้
+#-----------------------------------------------
+#print(data) #ทำการแสดงผลตัวแปร dataที่ได้
+
+

fileAPI.py

@@ -0,0 +1,22 @@
+import pandas as pd 
+import os
+from Twythonx import *
+
+class fileAPI:
+
+    def __init__(self,name):
+        self.fileName = name
+    
+    def readFile(self):
+        #open csv files
+        df = pd.read_csv(self.fileName)
+        tempDict = df.to_dict('list')
+        return tempDict
+
+    def writeFile(self,inDict):
+        #save files in csv form
+        df = pd.DataFrame(inDict)
+        df.to_csv(path_or_buf= self.fileName ,index=False)
+        return "success"
+        
+        

twythonxx.py

@@ -0,0 +1,82 @@
+from twython import Twython
+from twython import TwythonStreamer
+from datetime import date
+class TweetStreamer(TwythonStreamer):
+    def on_success(self, data):
+        if 'text' in data:
+            print (data['text'].encode('utf-8'))
+
+    def on_error(self, status_code, data):
+        print (status_code)
+        self.disconnect()
+class twit:
+    def __init__(self):
+        #define needed parameter for twitterapi to access twitter account
+        APP_KEY = 'X5gCNKpqL6NUsLvBJjIYIm4Pz'
+        APP_SECRET = 'UrlJVaRjpWmZrMjmWH7uADCBCzXwdoceIWVv2ftC34z85wpmMR'
+        OAUTH_TOKEN = '1267471839929880577-ks8UGM7ydtxJ8xWJpHtv55tUCVGh7Z'
+        OAUTH_TOKEN_SECRET = 'QjKJ2FLe3R6gGtGD17lyBauOAqfptcnK75B5Sk8qZRSYN'
+        self.twitter = Twython(APP_KEY, APP_SECRET,OAUTH_TOKEN, OAUTH_TOKEN_SECRET)
+        self.streamer = TweetStreamer(APP_KEY, APP_SECRET,
+                         OAUTH_TOKEN, OAUTH_TOKEN_SECRET)
+    def search(self,tag):
+        #q => searched quote
+        #result_type >> recent, popular, mixed
+        results = self.twitter.search(q=tag,result_type = 'recent')
+        #this function return results.keys() = ['statuses','meta_data'] we use only 'statuses' here
+        statuses  = results['statuses']
+        k = []
+        for i in range(len(statuses)) :
+            #collect wanted results ((( cd.keys() = ['screen_name','id_user','tweet_when','tweet_id','text'] )))
+            #in list ((( k )))
+            cd = dict()
+            cd['screen_name'] = statuses[i]['user']['screen_name']
+            cd['id_user'] = statuses[i]['user']['id']
+            cd['tweet_when'] = statuses[i]['created_at']
+            cd['tweet_id'] = statuses[i]['id']
+            cd['text'] = statuses[i]['text']
+            cd['location'] = statuses[i]['user']['location']
+            k.append(cd)
+        return(k)
+    def post(self,text):
+        #to post status,but can not spam the same tweet at the time. limit 300 tweets/3 hour for standard account 
+        self.twitter.update_status(status=text)
+    def search2(self,text,*args,**kwrgs):
+        #q => searched quote
+        #result_type >> recent, popular, mixed
+        defKwrgs = {'result_type' : 'recent','lang' :'en','count' : 15,'until': str(date.today())}
+        for k,item in kwrgs.items():
+            defKwrgs[k] = item
+
+        results = self.twitter.search(q=text,\
+            result_type = defKwrgs['result_type'],\
+            lang =defKwrgs['lang'],\
+            count = int(defKwrgs['count']),\
+            until = defKwrgs['until']    )
+        #this function return results.keys() = ['statuses','meta_data'] we use only 'statuses' here
+        statuses  = results['statuses']
+  
+    
+        #for arg in args:
+        k = []
+ 
+        for i,st in enumerate(statuses) :
+            #collect wanted results ((( cd.keys() = ['screen_name','id_user','tweet_when','tweet_id','text'] )))
+            #in list ((( k )))
+            cd = dict()
+
+            cd['screen_name'] = st['user']['screen_name']
+            cd['id_user'] = st['user']['id']
+            cd['tweet_when'] = st['created_at']
+            cd['tweet_id'] = st['id']
+            cd['text'] = st['text']
+            cd['location'] = st['user']['location']
+            temp = dict()
+            if args[0] == 'all': temp = cd
+            else:
+                for arg in args:
+                    temp[arg] = cd[arg]
+            k.append(temp)
+        return k
+    def stream(self,text):
+        self.streamer.statuses.filter(track = '#lisa')