equal
deleted
inserted
replaced
128 |
128 |
129 utils.set_logging(options) |
129 utils.set_logging(options) |
130 |
130 |
131 |
131 |
132 acess_token_key, access_token_secret = utils.get_oauth_token(consumer_key=options.consumer_key, consumer_secret=options.consumer_secret, token_file_path=options.token_filename, application_name=APPLICATION_NAME) |
132 acess_token_key, access_token_secret = utils.get_oauth_token(consumer_key=options.consumer_key, consumer_secret=options.consumer_secret, token_file_path=options.token_filename, application_name=APPLICATION_NAME) |
133 |
133 twitter_auth = twitter.OAuth(acess_token_key, access_token_secret, options.consumer_key, options.consumer_secret) |
134 t = twitter.Twitter(domain="api.twitter.com", auth=twitter.OAuth(acess_token_key, access_token_secret, options.consumer_key, options.consumer_secret), secure=True) |
134 |
|
135 t = twitter.Twitter(domain="api.twitter.com", auth=twitter_auth, secure=True) |
135 t.secure = True |
136 t.secure = True |
136 |
137 |
137 conn_str = options.conn_str.strip() |
138 conn_str = options.conn_str.strip() |
138 if not re.match(r"^\w+://.+", conn_str): |
139 if not re.match(r"^\w+://.+", conn_str): |
139 conn_str = 'sqlite:///' + conn_str |
140 conn_str = 'sqlite:///' + conn_str |
178 if e.e.code == 404 or e.e.code == 403: |
179 if e.e.code == 404 or e.e.code == 403: |
179 continue |
180 continue |
180 else: |
181 else: |
181 raise |
182 raise |
182 |
183 |
183 processor = TwitterProcessorStatus(tweet, None, None, session, None, options.token_filename, logger) |
184 processor = TwitterProcessorStatus(tweet, None, None, session, twitter_auth=twitter_auth, logger=logger) |
184 processor.process() |
185 processor.process() |
185 session.flush() |
186 session.flush() |
186 session.commit() |
187 session.commit() |
187 |
188 |
188 print("rate limit remaining %s of %s" % (str(tweet.rate_limit_remaining), str(tweet.headers['X-Rate-Limit-Limit'])) + term.clear_eol()) |
189 print("rate limit remaining %s of %s" % (str(tweet.rate_limit_remaining), str(tweet.headers['X-Rate-Limit-Limit'])) + term.clear_eol()) |