andyjk15/tweet-collector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[12.10.20] Testing

Browse Source
This commit is contained in:
andrewso 2020-10-12 17:48:57 +01:00
parent ab1288351c
commit f11b94df52
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/tweets/collector.py
View File

@ -69,18 +69,12 @@ class Streamer():
stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended') stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
stream.filter(languages=["en"], track=hashtag) stream.filter(languages=["en"], track=hashtag)
except IncompleteRead: except IncompleteRead:
stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
stream.filter(languages=["en"], track=hashtag)
log("Incomplete Read Error", 'ERR') log("Incomplete Read Error", 'ERR')
continue continue
except ProtocolError: except ProtocolError:
stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
stream.filter(languages=["en"], track=hashtag)
log("Protocol Error", 'ERR') log("Protocol Error", 'ERR')
continue continue
except: except:
stream = Stream(auth=api.auth, listener=listener, tweet_mode='extended')
stream.filter(languages=["en"], track=hashtag)
log("Some other Error", 'ERR') log("Some other Error", 'ERR')
continue continue
@ -123,7 +117,7 @@ def processTweet(text, type):
# processStack = dumpStack.copy() # processStack = dumpStack.copy()
# dumpStack.clear() # dumpStack.clear()
# log("Processing [{}] Tweets...".format(len(processStack)), 'INFO') log("Processing [{}] Tweet...".format(text), 'INFO')
# if len(processStack) != 0: # if len(processStack) != 0:
# for tweet in processStack: # for tweet in processStack: