Update pipeline.py

Author: devlinwaluja

pipeline/pipeline.py

@@ -1,9 +1,18 @@
-#
-# Flowmotion
-# Pipeline
-#
+from api import APIClient
+from TrafficImage import TrafficImage
 
 if __name__ == "__main__":
-    # TODO: pipeline code starts here
-    pass
-    
+    apiclient = APIClient("https://api.data.gov.sg/v1/transport/traffic-images")
+    active_cameraIDs = apiclient.camera_id_array
+    current_traffic_camera_objects = [] #array of TrafficImage objects
+
+#populating array of TrafficImage objects
+    for camera_id in active_cameraIDs:
+        image_url = apiclient.extract_image(camera_id)
+        longitude, latitude = apiclient.extract_latlon(camera_id)
+        traffic_camera_obj = TrafficImage(camera_id=camera_id, image=image_url, longitude=longitude, latitude=latitude)
+        current_traffic_camera_objects.append(traffic_camera_obj)
+
+    # MLmodel(current_traffic_camera_objects)
+
+