--- a/script/stream/recorder_tweetstream.py Fri Jul 01 10:06:01 2011 +0200
+++ b/script/stream/recorder_tweetstream.py Fri Jul 01 10:06:36 2011 +0200
@@ -8,6 +8,7 @@
import os
import socket
import sys
+import time
import tweetstream
import tweetstream.auth
socket._fileobject.default_bufsize = 0
@@ -106,6 +107,7 @@
print "Stop recording after %d seconds." % (duration)
break
process_tweet(tweet, session, debug, token_filename)
+ logging.info("Tweet count: %d - current rate : %d - running : %s"%(stream.count, stream.rate, int(time.time()-stream.starttime)))
session.commit()
finally:
stream.close()
@@ -149,7 +151,7 @@
if options.new and os.path.exists(options.filename):
os.remove(options.filename)
- engine, metadata = models.setup_database('sqlite:///' + options.filename, echo=(options.debug))
+ engine, metadata = models.setup_database('sqlite:///' + options.filename, echo=(options.debug>=2))
Session = sessionmaker(bind=engine)
session = Session()