script/utils/export_tweet_db.py
changeset 891 8628c590f608
parent 529 99215db3da25
--- a/script/utils/export_tweet_db.py	Wed May 08 01:24:19 2013 +0200
+++ b/script/utils/export_tweet_db.py	Fri May 10 13:27:42 2013 +0200
@@ -1,8 +1,11 @@
-from models import setup_database
-from optparse import OptionParser #@UnresolvedImport
-from sqlalchemy.orm import sessionmaker
-from utils import set_logging_options, set_logging, TwitterProcessor, logger
-import sqlite3 #@UnresolvedImport
+from iri_tweet.models import setup_database
+from iri_tweet.processor import TwitterProcessorStatus
+from iri_tweet.utils import set_logging_options, set_logging
+from optparse import OptionParser
+import logging
+import sqlite3
+
+logger = logging.getLogger(__name__)
 
 
 #    'entities': "tweet_entity",     
@@ -33,7 +36,7 @@
             fields_mapping = {}
             for i,res in enumerate(curs_in.execute("select json from tweet_tweet;")):
                 logger.debug("main loop %d : %s" % (i, res[0])) #@UndefinedVariable
-                processor = TwitterProcessor(eval(res[0]), res[0], None, session, options.token_filename)
+                processor = TwitterProcessorStatus(json_dict=eval(res[0]), json_txt=res[0], source_id=None, session=session, consumer_token=None, access_token=None, token_filename=options.token_filename, user_query_twitter=False, logger=logger)
                 processor.process()
                 session.commit()
             logger.debug("main : %d tweet processed" % (i+1)) #@UndefinedVariable