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

[15.10.20] Testing

Browse Source
This commit is contained in:
andrewso 2020-10-15 20:15:55 +01:00
parent 17bd1399cc
commit da43817926
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/utils/sentimentAnalyser.py
View File

@ -10,10 +10,13 @@ class keys():
self.sentiment_analyser_uri = os.getenv("SENTIMENT_URL") self.sentiment_analyser_uri = os.getenv("SENTIMENT_URL")
def callSentimentAnalyser(tweet, syncId): def callSentimentAnalyser(tweet, syncId):
# log("Calling Sentiment Analyser for [{}]".format(tweet), 'INFO') headers = {
"content-type":"text",
"X-CRYPTO-Sync-ID" : str(syncId)
}
try: try:
uri = keys().sentiment_analyser_uri + "/sentiment?tweet="+tweet uri = keys().sentiment_analyser_uri + "/sentiment?tweet="+tweet
response = requests.get(uri, headers={"X-CRYPTO-Sync-ID" : syncId}) response = requests.request("GET", url=uri, headers=headers)
response = json.loads(response.text) response = json.loads(response.text)
@ -21,5 +24,5 @@ def callSentimentAnalyser(tweet, syncId):
return scores["pos"], scores["neu"], scores["neg"], scores["compound"] return scores["pos"], scores["neu"], scores["neg"], scores["compound"]
except: except:
log("Could not call Sentiment Analyser Service", 'ERR') log("Could not call Sentiment Analyser Service with syncId of [{}]".format(syncId), 'ERR', syncId)
return 0, 0, 0, 0 return 0, 0, 0, 0

10
src/utils/spamFilter.py
View File

@ -10,15 +10,17 @@ class keys():
self.spamFilter_uri = os.getenv("FILTER_URL") self.spamFilter_uri = os.getenv("FILTER_URL")
def callSpamFilter(tweet, syncId): def callSpamFilter(tweet, syncId):
headers = {
"content-type":"text",
"X-CRYPTO-Sync-ID" : str(syncId)
}
try: try:
uri = keys().spamFilter_uri + "/predict?tweet="+tweet uri = keys().spamFilter_uri + "/predict?tweet="+tweet
response = requests.get(uri, headers={"X-CRYPTO-Sync-ID" : syncId}) response = requests.request("GET", url=uri, headers=headers)
response = json.loads(response.text) response = json.loads(response.text)
# log("Spam Filter result for [{}] is [{}]".format(tweet, response["result"]), 'INFO')
return response["result"] return response["result"]
except: except:
log("Could not call spam filter service", 'ERR') log("Could not call spam filter service with syncId of [{}]".format(syncId), 'ERR', syncId)
return "" return ""