minor fixes

* removed unused import
* renaming activity id for fitfile import (to adapt to the other sources)

kafka-producer/file/extractor.py

@@ -11,7 +11,7 @@ class FitFileActivityExtractor(ActivityExtractor):
 
     def __init__(self, file_stream):
         self.fitfile = FitFile(file_stream)
-        self.activity_id = uuid.uuid4()
+        self.activity_id = str(uuid.uuid4())
 
     def get_activity(self, id):
         raise NotImplementedError("One fit file always contains data for one activity only")
@@ -20,7 +20,7 @@ def get_activities(self):
         data = []
         for record in self.fitfile.get_messages('record'):
             record_dict = {metric.name: metric.value for metric in record}
-            record_dict.update({'activity_id': self.activity_id})
+            record_dict.update({'activityId': self.activity_id, 'type': 'fitfile_upload'})
             data.append(record_dict)
         return data
 

kafka-producer/strava/extractor.py

@@ -1,5 +1,3 @@
-
-import os
 import json
 import requests
 import os