equal
deleted
inserted
replaced
33 try: |
33 try: |
34 curs_in = conn_in.cursor() |
34 curs_in = conn_in.cursor() |
35 fields_mapping = {} |
35 fields_mapping = {} |
36 for i,res in enumerate(curs_in.execute("select json from tweet_tweet;")): |
36 for i,res in enumerate(curs_in.execute("select json from tweet_tweet;")): |
37 logging.debug("main loop %d : %s" % (i, res[0])) #@UndefinedVariable |
37 logging.debug("main loop %d : %s" % (i, res[0])) #@UndefinedVariable |
38 processor = TwitterProcessor(eval(res[0]), res[0], session, options.token_filename) |
38 processor = TwitterProcessor(eval(res[0]), res[0], None, session, options.token_filename) |
39 processor.process() |
39 processor.process() |
40 session.commit() |
40 session.commit() |
41 logging.debug("main : %d tweet processed" % (i+1)) #@UndefinedVariable |
41 logging.debug("main : %d tweet processed" % (i+1)) #@UndefinedVariable |
42 except Exception, e: |
42 except Exception, e: |
43 session.rollback() |
43 session.rollback() |