in social-media/gather-data.py [0:0]
def process_status(status, output_file_handle):
global sleep_before_get_status
global sleep_before_get_user
if status.retweeted_status is not None:
return False
record = {}
record.update(status_to_map('', status))
record.update(user_to_map('', status.user))
if record['in_reply_to_status_id'] is not None:
if sleep_before_get_status:
sleep_then_update_flags()
try:
r2status = twitter_api.GetStatus(record['in_reply_to_status_id'])
sleep_before_get_status = True
record.update(status_to_map('r.', r2status))
record.update(user_to_map('r.', r2status.user))
except TwitterError as e:
print(e)
print('statusId:' + str(record['in_reply_to_status_id']))
elif record['in_reply_to_user_id'] is not None:
if sleep_before_get_user:
sleep_then_update_flags()
try:
r2user = twitter_api.GetUser(int(record['in_reply_to_user_id']))
sleep_before_get_user = True
record.update(user_to_map('r.', r2user))
except TwitterError as e:
print(e)
print('statusId:' + str(record['in_reply_to_user_id']))
output_file_handle.write(json.dumps(record))
output_file_handle.write('\n')
return True