-
Notifications
You must be signed in to change notification settings - Fork 11
/
tweet_sender.py
35 lines (28 loc) · 1.18 KB
/
tweet_sender.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
import threading, queue, time, twitter
from housepy import config, log
class TweetSender(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
self.daemon = True
self.queue = queue.Queue()
self.sender = twitter.Twitter(auth=twitter.OAuth( config['twitter']['access_token'],
config['twitter']['access_token_secret'],
config['twitter']['consumer_key'],
config['twitter']['consumer_secret']
))
self.start()
def run(self):
while True:
message = self.queue.get()[:140]
log.info("SENDING TWEET: %s" % message)
try:
self.sender.statuses.update(status=message)
except Exception as e:
log.error(log.exc(e))
else:
log.info("--> sent")
if __name__ == "__main__":
tweet_sender = TweetSender()
tweet_sender.queue.put("A message")
while True:
time.sleep(1)