Skip to content

Commit

Permalink
refactored HF and twitter mapping to snake style code convention
Browse files Browse the repository at this point in the history
  • Loading branch information
Sieboldianus committed Jan 2, 2019
1 parent e34af34 commit fed1a4b
Show file tree
Hide file tree
Showing 6 changed files with 457 additions and 376 deletions.
2 changes: 1 addition & 1 deletion lbsntransform/__main__.py
Expand Up @@ -149,7 +149,7 @@ def main():

# submit remaining
# ??
if import_mapper.lbsn_records.CountGlob > 0:
if import_mapper.lbsn_records.count_glob > 0:
print(f'Transferring remaining {import_mapper.lbsn_records.CountGlob} to db.. '
f'{HF.null_notice(import_mapper.null_island)})')
output.storeLbsnRecordDicts(import_mapper)
Expand Down
12 changes: 6 additions & 6 deletions lbsntransform/classes/field_mapping_flickr.py
Expand Up @@ -60,18 +60,18 @@ def extract_flickr_post(self, record):
post_guid = record[5]
if not HF.check_notice_empty_post_guid(post_guid):
return None
postRecord = HF.createNewLBSNRecord_with_id(lbsnPost(),
postRecord = HF.create_new_lbsn_record_with_id(lbsnPost(),
post_guid,
self.origin)
postGeoaccuracy = None
userRecord = HF.createNewLBSNRecord_with_id(lbsnUser(),
userRecord = HF.create_new_lbsn_record_with_id(lbsnUser(),
record[7],
self.origin)
userRecord.user_name = record[6]
userRecord.url = f'http://www.flickr.com/photos/{userRecord.pkey.id}/'
if userRecord:
postRecord.user_pkey.CopyFrom(userRecord.pkey)
self.lbsn_records.AddRecordsToDict(userRecord)
self.lbsn_records.add_records_to_dict(userRecord)
postRecord.post_latlng = self.flickr_extract_postlatlng(record)
geoaccuracy = FieldMappingFlickr.flickr_map_geoaccuracy(record[13])
if geoaccuracy:
Expand All @@ -80,10 +80,10 @@ def extract_flickr_post(self, record):
# we need some information from postRecord to create placeRecord
# (e.g. user language, geoaccuracy, post_latlng)
# some of the information from place will also modify postRecord
placeRecord = HF.createNewLBSNRecord_with_id(lbsnPlace(),
placeRecord = HF.create_new_lbsn_record_with_id(lbsnPlace(),
record[19],
self.origin)
self.lbsn_records.AddRecordsToDict(placeRecord)
self.lbsn_records.add_records_to_dict(placeRecord)
postRecord.place_pkey.CopyFrom(placeRecord.pkey)
postRecord.post_publish_date.CopyFrom(HF.parse_csv_datestring_to_protobuf(record[9]))
postRecord.post_create_date.CopyFrom(HF.parse_csv_datestring_to_protobuf(record[8]))
Expand All @@ -107,7 +107,7 @@ def extract_flickr_post(self, record):
else:
postRecord.post_type = lbsnPost.IMAGE
postRecord.post_content_license = valueCount(record[14])
self.lbsn_records.AddRecordsToDict(postRecord)
self.lbsn_records.add_records_to_dict(postRecord)

@staticmethod
def reverse_csv_comma_replace(csv_string):
Expand Down

0 comments on commit fed1a4b

Please sign in to comment.